Browse Source

New option "queue" to 'task-sent' event

Roman Imankulov 13 years ago
parent
commit
359deaca7e
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

@@ -239,7 +239,8 @@ class TaskPublisher(messaging.Publisher):
                                                kwargs=repr(task_kwargs),
                                                retries=retries,
                                                eta=eta,
-                                               expires=expires)
+                                               expires=expires,
+                                               queue=queue)
         return task_id
 
     def __exit__(self, *exc_info):

+ 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.