This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch v1-10-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v1-10-test by this push:
new ff2f09c Execute job cancel HTTPRequest in Dataproc Hook (#10361)
ff2f09c is described below
commit ff2f09ca6f062ad4c6cf13d9e56a2b0cb39344a1
Author: Varun Dhussa <[email protected]>
AuthorDate: Wed Aug 19 14:10:16 2020 +0530
Execute job cancel HTTPRequest in Dataproc Hook (#10361)
closes: #10357
---
airflow/contrib/hooks/gcp_dataproc_hook.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/contrib/hooks/gcp_dataproc_hook.py
b/airflow/contrib/hooks/gcp_dataproc_hook.py
index aae4e7a..dec3618 100644
--- a/airflow/contrib/hooks/gcp_dataproc_hook.py
+++ b/airflow/contrib/hooks/gcp_dataproc_hook.py
@@ -337,7 +337,7 @@ class DataProcHook(GoogleCloudBaseHook):
projectId=project_id,
region=region,
jobId=job_id
- )
+ ).execute(num_retries=self.num_retries)
setattr(
