работы?
import asyncio
import websockets
from worker import conn
from rq.job import Job
async def get_status(job_id: str):
job = Job.fetch(job_id, connection=conn)
print(job.get_status())
async def job_status_info(websocket, path):
job_id = await websocket.recv()
print(job_id)
await get_status(job_id)
await websocket.send('Job done!')
start_server = websockets.serve(job_status_info, '0.0.0.0', 6789)
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()
Ничего не возвращает
кстати у тебя get_status ничего не ретюрнит
Обсуждают сегодня