File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
packages/service-library/src/servicelib/long_running_tasks Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change 1616 TryAgain ,
1717 retry_if_exception_type ,
1818 stop_after_delay ,
19- wait_fixed ,
19+ wait_exponential ,
2020)
2121
2222from ..background_task import create_periodic_task
4040_STATUS_UPDATE_CHECK_INTERNAL : Final [datetime .timedelta ] = datetime .timedelta (seconds = 1 )
4141
4242_TASK_REMOVAL_MAX_WAIT : Final [NonNegativeFloat ] = 60
43- _TASK_REMOVAL_WAIT_CHECK_INTERVAL : Final [NonNegativeFloat ] = 0.1
4443
4544
4645RegisteredTaskName : TypeAlias = str
@@ -411,7 +410,7 @@ async def remove_task(
411410 # wait for task to be removed since it might not have been running
412411 # in this process
413412 async for attempt in AsyncRetrying (
414- wait = wait_fixed ( _TASK_REMOVAL_WAIT_CHECK_INTERVAL ),
413+ wait = wait_exponential ( max = 2 ),
415414 stop = stop_after_delay (_TASK_REMOVAL_MAX_WAIT ),
416415 retry = retry_if_exception_type (TryAgain ),
417416 ):
You can’t perform that action at this time.
0 commit comments