Actually use any given default_timeout for queues.

main
Vincent Driessen 13 years ago
parent a5d9ed0a0d
commit 697a4a89f8

@ -122,7 +122,7 @@ class Queue(object):
'Functions from the __main__ module cannot be processed ' 'Functions from the __main__ module cannot be processed '
'by workers.') 'by workers.')
timeout = kwargs.pop('timeout', None) timeout = kwargs.pop('timeout', self._default_timeout)
job = Job.create(f, *args, connection=self.connection, **kwargs) job = Job.create(f, *args, connection=self.connection, **kwargs)
return self.enqueue_job(job, timeout=timeout) return self.enqueue_job(job, timeout=timeout)

Loading…
Cancel
Save