File tree Expand file tree Collapse file tree 3 files changed +5
-5
lines changed Expand file tree Collapse file tree 3 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -189,7 +189,7 @@ def watch(self):
189
189
Watch DataFlow Run from OCID.
190
190
"""
191
191
run_id = self .config ["execution" ]["run_id" ]
192
- interval = self .config ["execution" ][ "interval" ]
192
+ interval = self .config ["execution" ]. get ( "interval" )
193
193
with AuthContext (auth = self .auth_type , profile = self .profile ):
194
194
run = DataFlowRun .from_ocid (run_id )
195
195
run .watch (interval = interval )
Original file line number Diff line number Diff line change @@ -227,8 +227,8 @@ def watch(self):
227
227
Watch Job Run from OCID.
228
228
"""
229
229
run_id = self .config ["execution" ]["run_id" ]
230
- interval = self .config ["execution" ][ "interval" ]
231
- wait = self .config ["execution" ][ "wait" ]
230
+ interval = self .config ["execution" ]. get ( "interval" )
231
+ wait = self .config ["execution" ]. get ( "wait" )
232
232
with AuthContext (auth = self .auth_type , profile = self .profile ):
233
233
run = DataScienceJobRun .from_ocid (run_id )
234
234
run .watch (interval = interval , wait = wait )
Original file line number Diff line number Diff line change @@ -90,8 +90,8 @@ def watch(self) -> None:
90
90
Watch Pipeline Run from OCID.
91
91
"""
92
92
run_id = self .config ["execution" ]["run_id" ]
93
- log_type = self .config ["execution" ][ "log_type" ]
94
- interval = self .config ["execution" ][ "interval" ]
93
+ log_type = self .config ["execution" ]. get ( "log_type" )
94
+ interval = self .config ["execution" ]. get ( "interval" )
95
95
with AuthContext (auth = self .auth_type , profile = self .profile ):
96
96
PipelineRun .from_ocid (run_id ).watch (
97
97
interval = interval ,
You can’t perform that action at this time.
0 commit comments