This is an automated email from the ASF dual-hosted git repository.
eladkal 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 71306b31f1 Fix`GoogleCampaignManagerReportSensor` with `QUEUED` status
(#28735)
71306b31f1 is described below
commit 71306b31f1842ee2b1eb1cc2980b90f0fb6b11dc
Author: Kacper Muda <[email protected]>
AuthorDate: Mon Jan 9 09:41:03 2023 +0100
Fix`GoogleCampaignManagerReportSensor` with `QUEUED` status (#28735)
---
airflow/providers/google/marketing_platform/sensors/campaign_manager.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/airflow/providers/google/marketing_platform/sensors/campaign_manager.py
b/airflow/providers/google/marketing_platform/sensors/campaign_manager.py
index 88e727d50c..d8c0a3166c 100644
--- a/airflow/providers/google/marketing_platform/sensors/campaign_manager.py
+++ b/airflow/providers/google/marketing_platform/sensors/campaign_manager.py
@@ -73,7 +73,7 @@ class GoogleCampaignManagerReportSensor(BaseSensorOperator):
)
response = hook.get_report(profile_id=self.profile_id,
report_id=self.report_id, file_id=self.file_id)
self.log.info("Report status: %s", response["status"])
- return response["status"] != "PROCESSING"
+ return response["status"] not in ("PROCESSING", "QUEUED")
def __init__(
self,
