You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2022/08/16 13:35:55 UTC

[airflow] branch main updated: Fixed never ending loop to in CreateWorkflowInvocation (#25737)

This is an automated email from the ASF dual-hosted git repository.

potiuk 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 6e41c7eb33 Fixed never ending loop to in CreateWorkflowInvocation (#25737)
6e41c7eb33 is described below

commit 6e41c7eb33a68ea3ccd6b67fb169ea2cf1ecc162
Author: Ɓukasz Wyszomirski <wy...@google.com>
AuthorDate: Tue Aug 16 15:35:45 2022 +0200

    Fixed never ending loop to in CreateWorkflowInvocation (#25737)
---
 airflow/providers/google/cloud/hooks/dataform.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/providers/google/cloud/hooks/dataform.py b/airflow/providers/google/cloud/hooks/dataform.py
index 7e666486c5..f3dac6ce48 100644
--- a/airflow/providers/google/cloud/hooks/dataform.py
+++ b/airflow/providers/google/cloud/hooks/dataform.py
@@ -77,7 +77,7 @@ class DataformHook(GoogleBaseHook):
                     repository_id=repository_id,
                     workflow_invocation_id=workflow_invocation_id,
                 )
-                state = workflow_invocation
+                state = workflow_invocation.state
             except Exception as err:
                 self.log.info(
                     "Retrying. Dataform API returned error when waiting for workflow invocation: %s", err