clean up celery task states

Author: bisgaard-itis

services/api-server/src/simcore_service_api_server/_service_function_jobs_task_client.py

@@ -33,6 +33,7 @@
 from models_library.users import UserID
 from servicelib.celery.models import TaskMetadata, TasksQueue, TaskUUID
 from servicelib.celery.task_manager import TaskManager
+from servicelib.logging_errors import create_troubleshootting_log_kwargs
 from simcore_service_api_server.models.schemas.functions import (
     FunctionJobCreationTaskStatus,
 )
@@ -87,7 +88,15 @@ async def _celery_task_status(
             task_uuid=TaskUUID(job_creation_task_id), task_filter=task_filter
         )
         return FunctionJobCreationTaskStatus[task_status.task_state]
-    except TaskNotFoundError as e:
+    except TaskNotFoundError as err:
+        user_msg = f"Job creation task not found for task_uuid={TaskUUID(job_creation_task_id)}"
+        _logger.exception(
+            **create_troubleshootting_log_kwargs(
+                user_msg,
+                error=err,
+                tip="This probably means the celery task failed, because the task should have created the project_id.",
+            )
+        )
         return FunctionJobCreationTaskStatus.ERROR
 
 

services/api-server/src/simcore_service_api_server/models/schemas/functions.py

@@ -5,7 +5,7 @@
 from pydantic import BaseModel, ConfigDict, Field
 from servicelib.celery.models import TaskState
 
-RUN_JOB_TASK_STATUS_PREFIX: Final[str] = "RUN_JOB_TASK_STATUS_"
+RUN_JOB_TASK_STATUS_PREFIX: Final[str] = "JOB_TASK_RUN_STATUS_"
 
 
 class FunctionJobsListFilters(BaseModel):
@@ -43,10 +43,8 @@ class FunctionJobCreationTaskStatus(StrEnum):
     RETRY = f"{RUN_JOB_TASK_STATUS_PREFIX}RETRY"
     SUCCESS = f"{RUN_JOB_TASK_STATUS_PREFIX}SUCCESS"
     FAILURE = f"{RUN_JOB_TASK_STATUS_PREFIX}FAILURE"
-    NOT_YET_SCHEDULED = (
-        "Function job creation task not yet scheduled"  # api-server custom status
-    )
-    ERROR = "Function job creation failed"  # api-server custom status
+    NOT_YET_SCHEDULED = "JOB_TASK_NOT_YET_SCHEDULED"  # api-server custom status
+    ERROR = "JOB_TASK_CREATION_FAILED"  # api-server custom status
 
 
 assert {elm._name_ for elm in TaskState}.union({"NOT_YET_SCHEDULED", "ERROR"}) == {