[airflow] branch main updated: Fix endless loop of defer in cloud_build (#32387)

[potiuk]

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new becfb3c64f Fix endless loop of defer in cloud_build (#32387)
becfb3c64f is described below

commit becfb3c64f42533d6b8c6806c290952d84bc76a0
Author: tnk-ysk <61967017+tnk-...@users.noreply.github.com>
AuthorDate: Thu Jul 6 17:58:19 2023 +0900

    Fix endless loop of defer in cloud_build (#32387)
---
 airflow/providers/google/cloud/triggers/cloud_build.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/airflow/providers/google/cloud/triggers/cloud_build.py 
b/airflow/providers/google/cloud/triggers/cloud_build.py
index 5ec9eef3ca..e07dc93907 100644
--- a/airflow/providers/google/cloud/triggers/cloud_build.py
+++ b/airflow/providers/google/cloud/triggers/cloud_build.py
@@ -95,6 +95,7 @@ class CloudBuildCreateBuildTrigger(BaseTrigger):
                             "message": "Build completed",
                         }
                     )
+                    return
                 elif cloud_build_instance._pb.status in (
                     Build.Status.WORKING,
                     Build.Status.PENDING,
@@ -111,14 +112,17 @@ class CloudBuildCreateBuildTrigger(BaseTrigger):
                     Build.Status.EXPIRED,
                 ):
                     yield TriggerEvent({"status": "error", "message": 
cloud_build_instance.status_detail})
+                    return
                 else:
                     yield TriggerEvent(
                         {"status": "error", "message": "Unidentified status of 
Cloud Build instance"}
                     )
+                    return
 
             except Exception as e:
                 self.log.exception("Exception occurred while checking for 
Cloud Build completion")
                 yield TriggerEvent({"status": "error", "message": str(e)})
+                return
 
     def _get_async_hook(self) -> CloudBuildAsyncHook:
         return CloudBuildAsyncHook(gcp_conn_id=self.gcp_conn_id)