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 ?

have you installed redis package along with redis-server on your machine? — Viren Rajput
– Viren Rajput, Commented Mar 8, 2013 at 13:48

Eric Marcos · Accepted Answer · 2015-07-15 12:00:05Z

9

I had the same problem and the issue was that I missed this code in my project's __init__.py:

from __future__ import absolute_import

# This will make sure the app is always imported when
# Django starts so that shared_task will use this app.
from .celery import app as celery_app

I hope it will be useful to someone out there...

answered Jul 15, 2015 at 12:00

Eric Marcos

2,7172 gold badges16 silver badges12 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

Jinesh · Accepted Answer · 2016-11-07 08:49:56Z

7

Had the same problem, ended up realizing that rabbitmq and redis processes were stoped.

On mac, if those services were installed via homebrew, then you can verify whether those services are running by running following command on terminal,

brew services list

can restart services by, (if installed via brew)

brew services restart rabbitmq
brew services restart redis

answered Nov 7, 2016 at 8:49

Jinesh

2,6052 gold badges23 silver badges24 bronze badges

Comments

tuna · Accepted Answer · 2013-03-08 15:37:07Z

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.

answered Mar 8, 2013 at 15:37

tuna

6,37111 gold badges45 silver badges63 bronze badges

Comments

Sugandh Narola · Accepted Answer · 2024-01-09 07:01:19Z

1

I was facing same issue , and tried almost every solution from opensource , at the end i got solution which works 100% efficiently.

all you need to do is

inside

projects--->>init.py

file you have to add this two lines of code

code:

from __future__ import absolute_import

# This will make sure the app is always imported when
# Django starts so that shared_task will use this app.
from .celery import app as celery_app

#Django #celery #redis #celeryconnectionerror #connectionrefused

answered Jan 9, 2024 at 7:01

Sugandh Narola

112 bronze badges

Collectives™ on Stack Overflow

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

4 Answers 4

Comments

Comments

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

4 Answers 4

Comments

Comments

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related