The NodeJS binding for the Celery distributed task queue
node-celery is the NodeJS binding for the Celery distributed task queue.
Questions tagged [node-celery]
10 questions
35
votes
2 answers
Creating a Celery worker using node.js
Using node-celery, we can enable node to push Celery jobs to the task queue. How can we allow node to be a Celery worker and consume the queue?
Nyxynyx
- 61,411
- 155
- 482
- 830
28
votes
5 answers
Equivalent of Celery in Node JS
Please suggest an equivalent of Celery in Node JS to run asynchronous tasks.
I have been able to search for the following:
(Later)
Kue (Kue),
coffee-resque (coffee-resque)
cron (cron)
node-celery(node celery)
I have run both manual and automated…
garima
- 5,154
- 11
- 46
- 77
4
votes
0 answers
Node.js script (node-celery) call to celery task handles 'self' argument improperly
I created a celery task script as follows:
from celery import Task
from celery.contrib.methods import task
from celery.contrib.methods import task_method
from pipelines.addsub import settings
from pipelines.addsub.log import…
Ed Johns
- 211
- 3
- 11
2
votes
1 answer
Configure Celery with JSON Serializer (Python + node.js)
I'm running a Celery worker in Python with the celery module v3.1.25, and a Celery client in node.js with the node-celery npm package v0.2.7 (not the latest).
The Python Celery worker works fine when sending a job using a Python Celery…
Nyxynyx
- 61,411
- 155
- 482
- 830
2
votes
3 answers
Celery broadcast task not working
I've tried to make a broadcast task but only one of my workers recieve it per each call. Would you please help me? (I'm using rabbitmq and node-celery)
default_exchange = Exchange('celery', type='direct')
celery.conf.update(
…
Majid
- 638
- 6
- 21
1
vote
2 answers
How to define task in node-celery ?
I am using node-celery.
I just need to implement scheduling task so that Task can run on the background at the specific time.
I am confused how can I define my task, currently I am defining task at the same file where I am implementing…
Shivam Raj
- 23
- 5
1
vote
1 answer
how to use celery beat with node-celery
I am using node-celery github link to implement celery celery first step along with rabbitmq.
As in celery we define task and then we push them.
My task which I have defined inside tasks.py is as below:
import os
import logging
from celery import…
Always_a_learner
- 4,585
- 13
- 63
- 112
0
votes
1 answer
node-celery client.call('task') never executes/finishes?
I'm new to node-celery and am trying to start simple by getting a result from a celery task. I've written my JS in an 'await' fashion in order to wait for the result from the celery and then move forward, however, it seems the JS never gets a…
mmarion
- 859
- 8
- 20
0
votes
1 answer
node-celery redis backend unable to call duplicate()
I'm using node-celery (v0.2.8) with a redis backend. When I attempt to call celery.createClient(), I get this result:
self.redis.duplicate is not a function
In celery.js line 137 there's a call to redis.createClient(), then it attempts to call…
Daniel Vaughn
- 73
- 1
- 7
0
votes
1 answer
node-celery asychronise, await client.call() finish it's inner function
I am using node-celery 0.2.8 in my node.js server,and I create, use await on client.on(), hoping the code will console log result first, then log 'finally'. But the code console log 'finally' first, then after go through all the code, console log…
JACK
- 51
- 1
- 8