Skip to content

Commit d9d11a9

Browse files
committed
wait a bit for cleanup
1 parent 1a2adc7 commit d9d11a9

File tree

1 file changed

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

1 file changed

+3
-4
lines changed

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

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,9 @@
1212
from common_library.async_tools import cancel_wait_task
1313
from models_library.api_schemas_long_running_tasks.base import TaskProgress
1414
from pydantic import PositiveFloat
15-
from servicelib.background_task import create_periodic_task
16-
from servicelib.logging_utils import log_catch
1715

16+
from ..background_task import create_periodic_task
17+
from ..logging_utils import log_catch
1818
from .errors import (
1919
TaskAlreadyRunningError,
2020
TaskCancelledError,
@@ -33,7 +33,7 @@
3333
_DEFAULT_NAMESPACE: Final[str] = "lrt"
3434

3535
_CANCEL_TASK_TIMEOUT: Final[PositiveFloat] = datetime.timedelta(
36-
seconds=1
36+
seconds=10 # NOTE: 1 second is too short to cleanup a task
3737
).total_seconds()
3838

3939
RegisteredTaskName: TypeAlias = str
@@ -196,7 +196,6 @@ def _add_task(
196196
*,
197197
fire_and_forget: bool,
198198
) -> TrackedTask:
199-
200199
tracked_task = TrackedTask(
201200
task_id=task_id,
202201
task=task,

0 commit comments

Comments
 (0)