|
@@ -79,7 +79,8 @@ def apply_async(task, args=None, kwargs=None, countdown=None, eta=None,
|
|
replaced by a local :func:`apply` call instead.
|
|
replaced by a local :func:`apply` call instead.
|
|
|
|
|
|
"""
|
|
"""
|
|
- router = router or Router(conf.ROUTES, conf.get_queues())
|
|
|
|
|
|
+ router = router or Router(conf.ROUTES, conf.get_queues(),
|
|
|
|
+ conf.CREATE_MISSING_QUEUES)
|
|
|
|
|
|
if conf.ALWAYS_EAGER:
|
|
if conf.ALWAYS_EAGER:
|
|
return apply(task, args, kwargs, task_id=task_id)
|
|
return apply(task, args, kwargs, task_id=task_id)
|