fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-08 01:48:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #333 from tremby/fix-timeout-override

Browse Source 
Fix timeout override
This commit is contained in:
Ilan Steemers
2019-08-13 14:16:03 +02:00
committed by GitHub
parent 2a57c6c3c2 198ab59555
commit c27938ee62
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/cluster.py
+1 -1
View File
@@ -371,7 +371,7 @@ def worker(task_queue, result_queue, timer, timeout=Conf.TIMEOUT):
# We're still going # We're still going
if not result: if not result:
db.close_old_connections() db.close_old_connections()
timer_value = task['kwargs'].pop('timeout', timeout) timer_value = task.pop('timeout', timeout)
# signal execution # signal execution
pre_execute.send(sender="django_q", func=f, task=task) pre_execute.send(sender="django_q", func=f, task=task)
# execute the payload # execute the payload
django_q/tasks.py
+1 -1
View File
@@ -21,7 +21,7 @@ def async_task(func, *args, **kwargs):
"""Queue a task for the cluster.""" """Queue a task for the cluster."""
keywords = kwargs.copy() keywords = kwargs.copy()
opt_keys = ( opt_keys = (
'hook', 'group', 'save', 'sync', 'cached', 'ack_failure', 'iter_count', 'iter_cached', 'chain', 'broker') 'hook', 'group', 'save', 'sync', 'cached', 'ack_failure', 'iter_count', 'iter_cached', 'chain', 'broker', 'timeout')
q_options = keywords.pop('q_options', {}) q_options = keywords.pop('q_options', {})
# get an id # get an id
tag = uuid() tag = uuid()