File tree Expand file tree Collapse file tree 1 file changed +1
-6
lines changed
packages/service-library/src/servicelib/long_running_tasks Expand file tree Collapse file tree 1 file changed +1
-6
lines changed Original file line number Diff line number Diff line change 2929_logger = logging .getLogger (__name__ )
3030
3131
32- _CANCEL_TASK_TIMEOUT : Final [PositiveFloat ] = datetime .timedelta (
33- seconds = 10 # NOTE: 1 second is too short to cleanup a task
34- ).total_seconds ()
35-
3632_CANCEL_TASKS_CHECK_INTERVAL : Final [datetime .timedelta ] = datetime .timedelta (seconds = 5 )
3733_STATUS_UPDATE_CHECK_INTERNAL : Final [datetime .timedelta ] = datetime .timedelta (seconds = 1 )
3834
@@ -368,8 +364,7 @@ async def _cancel_tracked_task(
368364 ) -> None :
369365 try :
370366 await self ._tasks_data .set_as_cancelled (task_id , with_task_context )
371- # TODO: remove this cancellation timeout
372- await cancel_wait_task (task , max_delay = _CANCEL_TASK_TIMEOUT )
367+ await cancel_wait_task (task )
373368 except Exception as e : # pylint:disable=broad-except
374369 _logger .info (
375370 "Task %s cancellation failed with error: %s" ,
You can’t perform that action at this time.
0 commit comments