Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

add option to use rabitmq instead of redis for queue #38

Open
Mayukhdeb opened this issue Aug 20, 2022 · 0 comments
Open

add option to use rabitmq instead of redis for queue #38

Mayukhdeb opened this issue Aug 20, 2022 · 0 comments
Assignees
Labels
enhancement New feature or request

Comments

@Mayukhdeb
Copy link
Member

a minimal example of celery running with rabbitmq locally is as follows:

from celery import Celery
from eden.celery_utils import run_celery_app

'''
sudo service rabbitmq-server start
sudo rabbitmqctl add_user eden eden
 rabbitmqctl set_permissions -p / eden ".*' ".*" ".*"
'''

app = Celery(__name__, backend='rpc://', broker='amqp://eden:eden@localhost:5672/')

@app.task
def add(x, y):
    return x + y

run_celery_app(
    app = app
)
@Mayukhdeb Mayukhdeb added the enhancement New feature or request label Aug 20, 2022
@Mayukhdeb Mayukhdeb self-assigned this Aug 20, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request
Projects
None yet
Development

No branches or pull requests

1 participant