Python Celery socket.error: [Errno 61] Connection refused

Question

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

tasks.py

import celery



@celery.task

def function(x,y):

    return x + y

and function.py

from tasks import function



print function.delay(4,4).get()

I run the application with following command

celeryd --loglevel=INFO --config=celeryconfig

Everything is working great till now. I have redis and celery running and getting answers.

But when I run the function command from another file called parallelizer,

I get the socket error,

 socket.error: [Errno 61] Connection refused

My file is like below,

from examples.dummy.tasks import function

print function.delay(4,4).get()

Any ideas ?

Answer 1

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.

Python Celery socket.error: [Errno 61] Connection refused

Sign up