Start new job API

src/saturn_engine/core/api.py

@@ -177,6 +177,13 @@ class JobInput:
     error: Optional[str] = None
 
 
+@dataclasses.dataclass
+class StartJobInput:
+    name: JobId
+    queue_name: str
+    job_definition_name: str
+
+
 @dataclasses.dataclass
 class JobsResponse(ListResponse[JobItem]):
     items: list[JobItem]

src/saturn_engine/worker_manager/api/jobs.py

@@ -8,9 +8,11 @@
 from saturn_engine.core.api import JobsStatesSyncInput
 from saturn_engine.core.api import JobsStatesSyncResponse
 from saturn_engine.core.api import JobsSyncResponse
+from saturn_engine.core.api import StartJobInput
 from saturn_engine.core.api import UpdateResponse
 from saturn_engine.database import session_scope
 from saturn_engine.stores import jobs_store
+from saturn_engine.utils import utcnow
 from saturn_engine.utils.flask import Json
 from saturn_engine.utils.flask import abort
 from saturn_engine.utils.flask import check_found
@@ -93,3 +95,21 @@ def post_fetch_states() -> Json[FetchCursorsStatesResponse]:
             session=session,
         )
     return jsonify(FetchCursorsStatesResponse(cursors=cursors))
+
+
+@bp.route("/_start", methods=("POST",))
+def post_start_job() -> Json[JobResponse]:
+    start_input = marshall_request(StartJobInput)
+    with session_scope() as session:
+        job = jobs_store.get_job(session=session, name=start_input.name)
+        if job:
+            jobs_store.update_job(
+                session=session, name=start_input.name, completed_at=utcnow()
+            )
+        new_job = jobs_store.create_job(
+            session=session,
+            name=start_input.name,
+            queue_name=start_input.queue_name,
+            job_definition_name=start_input.job_definition_name,
+        )
+    return jsonify(JobResponse(data=new_job.as_core_item()))