Repository files navigation

    celery_app = Celery('module', broker='redis://redis:6379/0', backend='redis://redis:6379/0')

• 'module' - is the name of the worker ,
• Broker is Redis endpoint
• backend is Redis endpoint

• check simple_worker folder.

• check module worker
• inside module worker , there would be a python module called "module"
• setup celery and link tasks for this worker (celery.py)

• use in case when workers code does not need to be shared, separate Queues to be maintained
• control auto scaling independent of the worker.
• scale docker containers ??