MCPcopy Create free account
hub / github.com/taskforcesh/bullmq / processor

Method processor

python/tests/queue_events_test.py:64–65  ·  view source on GitHub ↗
(job: Job, token: str)

Source from the content-addressed store, hash-verified

62 )
63
64 async def processor(job: Job, token: str):
65 return {"answer": 42, "ok": True}
66
67 worker = Worker(queue_name, processor, {"prefix": prefix})
68 queue = Queue(queue_name, {"prefix": prefix})

Callers

nothing calls this directly

Calls 1

getMethod · 0.65

Tested by

no test coverage detected