Browse Source

Merge branch 'imankulov/pull_request'

Ask Solem 13 years ago
parent
commit
dc0a42842f
2 changed files with 3 additions and 2 deletions
  1. 2 1
      celery/app/amqp.py
  2. 1 1
      docs/userguide/monitoring.rst

+ 2 - 1
celery/app/amqp.py

@@ -205,7 +205,8 @@ class TaskProducer(Producer):
                                                kwargs=repr(task_kwargs),
                                                retries=retries,
                                                eta=eta,
-                                               expires=expires)
+                                               expires=expires,
+                                               queue=queue)
         return task_id
 TaskPublisher = TaskProducer  # compat
 

+ 1 - 1
docs/userguide/monitoring.rst

@@ -540,7 +540,7 @@ This list contains the events sent by the worker, and their arguments.
 Task Events
 ~~~~~~~~~~~
 
-* ``task-sent(uuid, name, args, kwargs, retries, eta, expires)``
+* ``task-sent(uuid, name, args, kwargs, retries, eta, expires, queue)``
 
    Sent when a task message is published and
    the :setting:`CELERY_SEND_TASK_SENT_EVENT` setting is enabled.