External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-03-02 09:18:48 -03:30
Code Issues Packages Projects Releases Wiki Activity

Fix up event emission to send the right thigns

Browse Source
This commit is contained in:
Matthew Jones
2014-04-18 14:42:23 -04:00
parent 007df8c5a6
commit 2177d6feab
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
awx/main/signals.py
View File

@@ -99,17 +99,25 @@ def emit_job_event_detail(sender, **kwargs):
instance = kwargs['instance'] instance = kwargs['instance']
created = kwargs['created'] created = kwargs['created']
if created: if created:
#event_serialized = JobEventSerializer(instance).data if instance.host is not None:
host_id = instance.host.id
else:
host_id = None
if instance.parent is not None:
parent_id = instance.parent.id
else:
parent_id = None
event_serialized = dict(job_id=instance.job.id, event_serialized = dict(job_id=instance.job.id,
event=instance.event, event=instance.event,
event_data=instance.event_data, event_data=instance.event_data,
failed=instance.failed, failed=instance.failed,
changed=instance.changed, changed=instance.changed,
host=instance.host.id,
play=instance.play, play=instance.play,
role=instance.role, role=instance.role,
task=instance.task) task=instance.task,
emit_websocket_notification('/socket.io/job_events', 'job_events-' + str(instance.id), event_serialized) host = host_id,
parent = parent_id)
emit_websocket_notification('/socket.io/job_events', 'job_events-' + str(instance.job.id), event_serialized)
post_save.connect(update_inventory_computed_fields, sender=Host) post_save.connect(update_inventory_computed_fields, sender=Host)
post_delete.connect(update_inventory_computed_fields, sender=Host) post_delete.connect(update_inventory_computed_fields, sender=Host)