mirror of
https://github.com/vale981/ray
synced 2025-03-06 02:21:39 -05:00
[Workflow] Fix flaky example(#26960)
Signed-off-by: Siyuan Zhuang <suquark@gmail.com>
This commit is contained in:
parent
e8222ff600
commit
0e1b77d52a
1 changed files with 3 additions and 1 deletions
|
@ -38,6 +38,8 @@ def custom_retry_strategy(func: Any, num_retries: int, delay_s: int) -> str:
|
|||
|
||||
if __name__ == "__main__":
|
||||
# Default retry strategy.
|
||||
print(workflow.run(flaky_step.options(max_retries=10).bind()))
|
||||
print(
|
||||
workflow.run(flaky_step.options(max_retries=10, retry_exceptions=True).bind())
|
||||
)
|
||||
# Custom strategy.
|
||||
print(workflow.run(custom_retry_strategy.bind(flaky_step, 10, 1)))
|
||||
|
|
Loading…
Add table
Reference in a new issue