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 <andrey.ans...@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