This is an automated email from the ASF dual-hosted git repository.
vincbeck 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 51c94e12eb fix(microsoft/azure): add return statement to yield within
a while loop in triggers (#38393)
51c94e12eb is described below
commit 51c94e12eb42f542135eaec52d0bb2dce18b01a5
Author: Wei Lee <[email protected]>
AuthorDate: Fri Mar 22 22:27:25 2024 +0800
fix(microsoft/azure): add return statement to yield within a while loop in
triggers (#38393)
---
airflow/providers/microsoft/azure/triggers/wasb.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/airflow/providers/microsoft/azure/triggers/wasb.py
b/airflow/providers/microsoft/azure/triggers/wasb.py
index 7eb92d8991..0a19bb6b12 100644
--- a/airflow/providers/microsoft/azure/triggers/wasb.py
+++ b/airflow/providers/microsoft/azure/triggers/wasb.py
@@ -78,6 +78,7 @@ class WasbBlobSensorTrigger(BaseTrigger):
if blob_exists:
message = f"Blob {self.blob_name} found in container
{self.container_name}."
yield TriggerEvent({"status": "success", "message":
message})
+ return
else:
message = (
f"Blob {self.blob_name} not available yet in
container {self.container_name}."
@@ -154,6 +155,7 @@ class WasbPrefixSensorTrigger(BaseTrigger):
if prefix_exists:
message = f"Prefix {self.prefix} found in container
{self.container_name}."
yield TriggerEvent({"status": "success", "message":
message})
+ return
else:
message = (
f"Prefix {self.prefix} not available yet in
container {self.container_name}."
