Skip to content

Commit a15cfbe

Browse files
author
Andrei Neagu
committed
rename
1 parent 78a9f09 commit a15cfbe

File tree

1 file changed

+3
-3
lines changed
  • packages/service-library/src/servicelib/long_running_tasks

1 file changed

+3
-3
lines changed

packages/service-library/src/servicelib/long_running_tasks/task.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -282,7 +282,7 @@ async def _stale_tasks_monitor(self) -> None:
282282
# we just print the status from where one can infer the above
283283
with suppress(TaskNotFoundError):
284284
task_status = await self.get_task_status(
285-
task_id, with_task_context=task_context, exclude_removed=False
285+
task_id, with_task_context=task_context, exclude_to_remove=False
286286
)
287287
with log_context(
288288
_logger,
@@ -424,15 +424,15 @@ async def get_task_status(
424424
task_id: TaskId,
425425
with_task_context: TaskContext,
426426
*,
427-
exclude_removed: bool = True,
427+
exclude_to_remove: bool = True,
428428
) -> TaskStatus:
429429
"""
430430
returns: the status of the task, along with updates
431431
form the progress
432432
433433
raises TaskNotFoundError if the task cannot be found
434434
"""
435-
if exclude_removed and await self._tasks_data.is_marked_for_removal(task_id):
435+
if exclude_to_remove and await self._tasks_data.is_marked_for_removal(task_id):
436436
raise TaskNotFoundError(task_id=task_id)
437437

438438
task_data = await self._get_tracked_task(task_id, with_task_context)

0 commit comments

Comments
 (0)