Convert execution dict values to str (apache#27165)

rkarish · Oct 29, 2022 · 7972f1e · 7972f1e
1 parent 5df1d6e
commit 7972f1e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/airflow/providers/google/cloud/hooks/workflows.py b/airflow/providers/google/cloud/hooks/workflows.py
@@ -241,6 +241,7 @@ def create_execution(
         metadata = metadata or ()
         client = self.get_executions_client()
         parent = f"projects/{project_id}/locations/{location}/workflows/{workflow_id}"
+        execution = {k: str(v) if isinstance(v, dict) else v for k, v in execution.items()}
         return client.create_execution(
             request={"parent": parent, "execution": execution},
             retry=retry,