File tree Expand file tree Collapse file tree 1 file changed +10
-10
lines changed
tests/integration/functional/utils Expand file tree Collapse file tree 1 file changed +10
-10
lines changed Original file line number Diff line number Diff line change @@ -94,8 +94,8 @@ def execution_mode_pipeline(fail_step_2: bool = False) -> None:
94
94
output_4 = step_4 (output_1 )
95
95
96
96
# These steps depend on the steps above
97
- output_5 = step_5 (output_2 )
98
- output_6 = step_6 (output_3 )
97
+ output_5 = step_5 (output_2 )
98
+ output_6 = step_6 (output_3 )
99
99
output_7 = step_7 (output_4 )
100
100
101
101
# Final step
@@ -119,14 +119,14 @@ def test_build_dag_with_downstream_steps(clean_client):
119
119
120
120
# Expected DAG structure based on our pipeline
121
121
expected_structure = {
122
- "step_1" : {"step_2" , "step_3" , "step_4" },
123
- "step_2" : {"step_5" },
124
- "step_3" : {"step_6" },
125
- "step_4" : {"step_7" },
126
- "step_5" : {"step_8" },
127
- "step_6" : {"step_8" },
128
- "step_7" : {"step_8" },
129
- "step_8" : set (),
122
+ "step_1" : {"step_2" , "step_3" , "step_4" },
123
+ "step_2" : {"step_5" },
124
+ "step_3" : {"step_6" },
125
+ "step_4" : {"step_7" },
126
+ "step_5" : {"step_8" },
127
+ "step_6" : {"step_8" },
128
+ "step_7" : {"step_8" },
129
+ "step_8" : set (),
130
130
}
131
131
132
132
assert dag == expected_structure
You can’t perform that action at this time.
0 commit comments