Skip to content

Commit

Permalink
turn on acks late
Browse files Browse the repository at this point in the history
also turn back on started so can tell difference with pending.
  • Loading branch information
hpiwowar committed Jun 17, 2014
1 parent 601f0b6 commit f4a84d6
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions celeryconfig.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
CELERY_DEFAULT_QUEUE = 'core_high'
CELERY_QUEUES = [
Queue('core_high', routing_key='core_high'),
Queue('core_low', routing_key='core_low'),
Queue('core_low', routing_key='core_low')
]

# added because https://github.com/celery/celery/issues/896
Expand All @@ -31,14 +31,16 @@
CELERY_CREATE_MISSING_QUEUES = True

CELERY_ACCEPT_CONTENT = ['pickle', 'json']
CELERY_ENABLE_UTC=True
CELERY_ENABLE_UTC = True
CELERY_TASK_RESULT_EXPIRES = 60*60 # 1 hour

CELERY_ACKS_LATE = True

# remove this, might fix deadlocks as per https://github.com/celery/celery/issues/970
# CELERYD_MAX_TASKS_PER_CHILD = 1000

CELERYD_FORCE_EXECV = True
# CELERY_TRACK_STARTED = True
CELERY_TRACK_STARTED = True

# List of modules to import when celery starts.
CELERY_IMPORTS = ("tasks",)
Expand Down

0 comments on commit f4a84d6

Please sign in to comment.