File tree 1 file changed +4
-4
lines changed
pipelines/rj_cor/meteorologia/precipitacao_alertario
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change 40
40
get_current_flow_labels ,
41
41
)
42
42
43
- wait_for_flow_run_with_2min_timeout = wait_for_flow_run_with_timeout (
44
- timeout = timedelta (minutes = 2 )
43
+ wait_for_flow_run_with_5min_timeout = wait_for_flow_run_with_timeout (
44
+ timeout = timedelta (minutes = 5 )
45
45
)
46
46
47
47
with Flow (
120
120
current_flow_labels .set_upstream (run_dbt )
121
121
materialization_flow .set_upstream (current_flow_labels )
122
122
123
- wait_for_materialization = wait_for_flow_run_with_2min_timeout (
123
+ wait_for_materialization = wait_for_flow_run_with_5min_timeout (
124
124
flow_run_id = materialization_flow ,
125
125
stream_states = True ,
126
126
stream_logs = True ,
200
200
)
201
201
dump_to_gcs_flow .set_upstream (wait_for_materialization )
202
202
203
- wait_for_dump_to_gcs = wait_for_flow_run_with_2min_timeout (
203
+ wait_for_dump_to_gcs = wait_for_flow_run_with_5min_timeout (
204
204
flow_run_id = dump_to_gcs_flow ,
205
205
stream_states = True ,
206
206
stream_logs = True ,
You can’t perform that action at this time.
0 commit comments