You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@airflow.apache.org by ka...@apache.org on 2020/08/22 18:26:31 UTC

[airflow] 03/03: Execute job cancel HTTPRequest in Dataproc Hook (#10361)

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

commit ae12c52a15f4d183117e160cf196188341d1639a
Author: Varun Dhussa <26...@users.noreply.github.com>
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(