This is an automated email from the ASF dual-hosted git repository.
shahar 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 1cda5b31cb5 Change Dataform system test to avoid race condition and
infinite execution (#61543)
1cda5b31cb5 is described below
commit 1cda5b31cb565df25d8c00a274ee0232d9a65baf
Author: Nitochkin <[email protected]>
AuthorDate: Fri Feb 6 21:10:17 2026 +0100
Change Dataform system test to avoid race condition and infinite execution
(#61543)
---
.../tests/system/google/cloud/dataform/example_dataform.py | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
diff --git
a/providers/google/tests/system/google/cloud/dataform/example_dataform.py
b/providers/google/tests/system/google/cloud/dataform/example_dataform.py
index a9380572adc..cfcee0b18a8 100644
--- a/providers/google/tests/system/google/cloud/dataform/example_dataform.py
+++ b/providers/google/tests/system/google/cloud/dataform/example_dataform.py
@@ -179,6 +179,12 @@ with DAG(
"{{
task_instance.xcom_pull('create-workflow-invocation-async')['name'].split('/')[-1]
}}"
),
expected_statuses={WorkflowInvocation.State.SUCCEEDED},
+ failure_statuses={
+ WorkflowInvocationAction.State.SKIPPED,
+ WorkflowInvocationAction.State.DISABLED,
+ WorkflowInvocationAction.State.CANCELLED,
+ WorkflowInvocationAction.State.FAILED,
+ },
)
# [END howto_operator_create_workflow_invocation_async]
@@ -341,7 +347,7 @@ with DAG(
>> delete_dataset
)
(
- last_initialization_step
+ remove_test_directory
>> install_npm_packages
>> create_compilation_result
>> [
@@ -358,7 +364,8 @@ with DAG(
)
(
create_workflow_invocation_async
- >> [is_workflow_invocation_done, is_workflow_invocation_action_done]
+ >> is_workflow_invocation_done
+ >> is_workflow_invocation_action_done
>> delete_dataset
)
create_workflow_invocation_for_cancel >> cancel_workflow_invocation >>
delete_dataset
