File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -26,11 +26,11 @@ async def create_task(message: str) -> dict[str, str]:
2626 """
2727 if queue .pool is None :
2828 raise HTTPException (status_code = 503 , detail = "Queue is not available" )
29-
29+
3030 job = await queue .pool .enqueue_job ("sample_background_task" , message )
3131 if job is None :
3232 raise HTTPException (status_code = 500 , detail = "Failed to create task" )
33-
33+
3434 return {"id" : job .job_id }
3535
3636
@@ -50,10 +50,10 @@ async def get_task(task_id: str) -> dict[str, Any] | None:
5050 """
5151 if queue .pool is None :
5252 raise HTTPException (status_code = 503 , detail = "Queue is not available" )
53-
53+
5454 job = ArqJob (task_id , queue .pool )
5555 job_info = await job .info ()
5656 if job_info is None :
5757 return None
58-
58+
5959 return job_info .__dict__
You can’t perform that action at this time.
0 commit comments