Commit 4d8fc500 authored by David Douard's avatar David Douard
Browse files

[ccplugin] do not listen to task-sent event (closes #16687268)

Do not create a CeleryTask if no worker has aknowledge the said task.
parent e55980c1a554
......@@ -81,7 +81,6 @@ class CeleryMonitorCommand(Command):
handlers={
'task-failed': self.on_event,
'task-succeeded': self.on_event,
'task-sent': self.on_event,
'task-received': self.on_event,
'task-revoked': self.on_event,
'task-started': self.on_event,
......
......@@ -303,7 +303,7 @@ class CeleryTaskAdapter(ICeleryTask):
@staticmethod
def on_event(cnx, event):
# handle weaving of parent_task relations
if event['type'] in ('task-received', 'task-sent'):
if event['type'] in ('task-received', ):
# may create the cw task entity, if needed
rset = cnx.find('CeleryTask', task_id=event['uuid'])
if not rset: # and 'name' in event:
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment