File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
packages/service-library/src/servicelib/long_running_tasks Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -74,7 +74,7 @@ def __init__(
7474 # Task groups: Every taskname maps to multiple asyncio.Task within TrackedTask model
7575 self ._tasks_groups : dict [TaskName , TrackedTaskGroupDict ] = {}
7676
77- self .stale_task_check_interval : datetime . timedelta = stale_task_check_interval
77+ self .stale_task_check_interval = stale_task_check_interval
7878 self .stale_task_detect_timeout_s : PositiveFloat = (
7979 stale_task_detect_timeout .total_seconds ()
8080 )
@@ -85,7 +85,7 @@ async def setup(self) -> None:
8585 self ._stale_tasks_monitor_task = create_periodic_task (
8686 task = self ._stale_tasks_monitor_worker ,
8787 interval = self .stale_task_check_interval ,
88- task_name = f"{ __name__ } .stale_task_monitor_worker " ,
88+ task_name = f"{ __name__ } .{ self . _stale_tasks_monitor_worker . __name__ } " ,
8989 )
9090
9191 async def teardown (self ) -> None :
You can’t perform that action at this time.
0 commit comments