File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
packages/service-library/src/servicelib/long_running_tasks Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -272,9 +272,9 @@ async def _cancelled_tasks_removal(self) -> None:
272272 """
273273 self ._started_event_task_cancelled_tasks_removal .set ()
274274
275- cancelled_tasks = await self ._tasks_data .get_all_to_remove ()
276- for task_id in cancelled_tasks :
277- await self ._attempt_cancel_and_remove_local_task (task_id )
275+ to_remove = await self ._tasks_data .get_all_to_remove ()
276+ for task_id in to_remove :
277+ await self ._attempt_to_remove_local_task (task_id )
278278
279279 async def _status_update (self ) -> None :
280280 """
@@ -388,8 +388,8 @@ async def get_task_result(
388388
389389 return string_to_object (tracked_task .result_field .result )
390390
391- async def _attempt_cancel_and_remove_local_task (self , task_id : TaskId ) -> None :
392- """if task is running in the local process, cancel it and remove it"""
391+ async def _attempt_to_remove_local_task (self , task_id : TaskId ) -> None :
392+ """if task is running in the local process, try to remove it"""
393393
394394 task_to_cancel = self ._created_tasks .pop (task_id , None )
395395 if task_to_cancel is not None :
You can’t perform that action at this time.
0 commit comments