We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7851fc3 commit 389c51dCopy full SHA for 389c51d
1 file changed
src/app/api/v1/tasks.py
@@ -26,11 +26,11 @@ async def create_task(message: str) -> dict[str, str]:
26
"""
27
if queue.pool is None:
28
raise HTTPException(status_code=503, detail="Queue is not available")
29
-
+
30
job = await queue.pool.enqueue_job("sample_background_task", message)
31
if job is None:
32
raise HTTPException(status_code=500, detail="Failed to create task")
33
34
return {"id": job.job_id}
35
36
@@ -50,10 +50,10 @@ async def get_task(task_id: str) -> dict[str, Any] | None:
50
51
52
53
54
job = ArqJob(task_id, queue.pool)
55
job_info = await job.info()
56
if job_info is None:
57
return None
58
59
return job_info.__dict__
0 commit comments