celery_app2.py 311 B

123456789
  1. from celery import Celery
  2. celery_app2 = Celery(
  3. "tasks",
  4. broker="redis://:Pheecian1@47.101.198.30:6379/2",
  5. backend="redis://:Pheecian1@47.101.198.30:6379/3",
  6. )
  7. celery_app2.conf.update(redis_socket_timeout=30)
  8. celery_app2.conf.update(redis_retry_on_timeout=True)
  9. celery_app2.conf.update(task_track_started=True)