You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ep...@apache.org on 2023/11/23 07:29:02 UTC
(airflow) 22/37: Fix DataFusion example type annotations (#35753)
This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a commit to branch v2-8-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 599189e41e27a3b30a2e2d3f598f9b45a96b8547
Author: Andrey Anshin <An...@taragol.is>
AuthorDate: Tue Nov 21 23:44:09 2023 +0400
Fix DataFusion example type annotations (#35753)
---
tests/system/providers/google/cloud/datafusion/example_datafusion.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/tests/system/providers/google/cloud/datafusion/example_datafusion.py b/tests/system/providers/google/cloud/datafusion/example_datafusion.py
index 38f443a706..506323dccb 100644
--- a/tests/system/providers/google/cloud/datafusion/example_datafusion.py
+++ b/tests/system/providers/google/cloud/datafusion/example_datafusion.py
@@ -215,7 +215,7 @@ with DAG(
# [END howto_cloud_data_fusion_update_instance_operator]
@task(task_id="get_artifacts_versions")
- def get_artifacts_versions(ti) -> dict:
+ def get_artifacts_versions(ti=None):
hook = DataFusionHook()
instance_url = ti.xcom_pull(task_ids="get_instance", key="return_value")["apiEndpoint"]
artifacts = hook.get_instance_artifacts(instance_url=instance_url, namespace="default")
@@ -319,7 +319,7 @@ with DAG(
# TEST BODY
>> create_instance
>> get_instance
- >> get_artifacts_versions() # type: ignore[call-arg]
+ >> get_artifacts_versions()
>> restart_instance
>> update_instance
>> create_pipeline