File tree 1 file changed +7
-5
lines changed
1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change @@ -202,15 +202,17 @@ def watch(
202
202
Status check frequency will be close to min_check_delay for the first 11 minutes,
203
203
and gradually approaches max_check_delay after 23 minutes.
204
204
205
- A close mimic to async is to use _get_kfp_run above.
206
- Implementation for async is not prioritized until specifically requested.
207
-
208
- TODO(yunw)(AIP-5671): Async version
205
+ Args:
206
+ run_id: Argo workflow run id.
207
+ wait_timeout: Wait timeout in seconds or datetime.timedelta.
208
+ min_check_delay: Minimum check delay in seconds.
209
+ max_check_delay: Maximum check delay in seconds.
210
+ assert_success: Whether to throw exception if run is not successful.
209
211
"""
210
212
211
213
def get_delay (secs_since_start , min_delay , max_delay ):
212
214
"""
213
- this sigmoid function reaches
215
+ This sigmoid function reaches
214
216
- 0.1 after 11 minutes
215
217
- 0.5 after 15 minutes
216
218
- 1.0 after 23 minutes
You can’t perform that action at this time.
0 commit comments