Skip to content

Commit aa08b2a

Browse files
add enum
1 parent 50550b4 commit aa08b2a

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

services/storage/src/simcore_service_storage/modules/celery/models.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
class TaskState(StrEnum):
1414
PENDING = auto()
1515
STARTED = auto()
16+
PROGRESS = auto()
1617
SUCCESS = auto()
1718
FAILURE = auto()
1819
ABORTED = auto()

services/storage/src/simcore_service_storage/modules/celery/worker.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
from models_library.progress_bar import ProgressReport
77
from servicelib.logging_utils import log_context
88

9-
from .models import TaskID
9+
from .models import TaskID, TaskState
1010

1111
_logger = logging.getLogger(__name__)
1212

@@ -30,6 +30,6 @@ def set_task_progress(
3030
):
3131
self.celery_app.tasks[task_name].update_state(
3232
task_id=task_id,
33-
state="PROGRESS",
33+
state=TaskState.PROGRESS.value,
3434
meta=report.model_dump(mode="json"),
3535
)

0 commit comments

Comments
 (0)