Update backend/queue.py
Browse files- backend/queue.py +2 -3
backend/queue.py
CHANGED
|
@@ -1,7 +1,7 @@
|
|
| 1 |
import asyncio
|
| 2 |
import uuid
|
| 3 |
-
|
| 4 |
-
from
|
| 5 |
|
| 6 |
class JobQueue:
|
| 7 |
async def add_job(self, req, token):
|
|
@@ -24,7 +24,6 @@ class JobQueue:
|
|
| 24 |
await db.create_job(job_id, params)
|
| 25 |
return job_id
|
| 26 |
|
| 27 |
-
# (process_jobs, get_queue_status は変更なし)
|
| 28 |
async def process_jobs(self):
|
| 29 |
while True:
|
| 30 |
job = await db.get_next_pending()
|
|
|
|
| 1 |
import asyncio
|
| 2 |
import uuid
|
| 3 |
+
import db
|
| 4 |
+
from worker import run_job_async
|
| 5 |
|
| 6 |
class JobQueue:
|
| 7 |
async def add_job(self, req, token):
|
|
|
|
| 24 |
await db.create_job(job_id, params)
|
| 25 |
return job_id
|
| 26 |
|
|
|
|
| 27 |
async def process_jobs(self):
|
| 28 |
while True:
|
| 29 |
job = await db.get_next_pending()
|