This is an automated email from the ASF dual-hosted git repository.
joshfell 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 f6148e6e33 Update dataplex.py (#40041)
f6148e6e33 is described below
commit f6148e6e33afb5c2ce1e0644b6f1b86d004ebd2b
Author: Amir Mor <[email protected]>
AuthorDate: Tue Jun 4 23:18:30 2024 +0300
Update dataplex.py (#40041)
Add job_id to template_fields, in order to easily provide returned value
from DataplexRunDataQualityScanOperator (the returned value is the triggered
job_id), to avoid List operations
---
airflow/providers/google/cloud/operators/dataplex.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/providers/google/cloud/operators/dataplex.py
b/airflow/providers/google/cloud/operators/dataplex.py
index 16276c4ee8..04edc10795 100644
--- a/airflow/providers/google/cloud/operators/dataplex.py
+++ b/airflow/providers/google/cloud/operators/dataplex.py
@@ -1067,7 +1067,7 @@ class
DataplexGetDataQualityScanResultOperator(GoogleCloudBaseOperator):
is available.
"""
- template_fields = ("project_id", "data_scan_id", "impersonation_chain")
+ template_fields = ("project_id", "data_scan_id", "impersonation_chain",
"job_id")
def __init__(
self,
