I am using Celery 3.0 and have the configuration file like below.
celeryconfig.py
BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_IMPORTS = ("tasks", )
CELERY_TASK_RESULT_EXPIRES = 300
import celery
@celery.task
def function(x,y):
return x + y
from tasks import function
print function.delay(4,4).get()
celeryd --loglevel=INFO --config=celeryconfig
socket.error: [Errno 61] Connection refused
from examples.dummy.tasks import function
print function.delay(4,4).get()
Problem was,
I was running celeryconfig.py under from a different path than my parallelizer.
When I carried the celeryconfig.py to same path with paralellizer it fixed the issue.