Set up post_process flag for JobEvent save in callback receiver.

This commit is contained in:
Aaron Tan 2016-09-28 14:14:29 -04:00
parent 609a3e6f2f
commit 38f5ae21f8

View File

@ -117,7 +117,7 @@ class CallbackBrokerWorker(ConsumerMixin):
else:
print("Cache hit")
j.parent_id = parent_id
j.save()
j.save(post_process=True)
if event_uuid:
cache.set("{}_{}".format(payload['job_id'], event_uuid), j.id, 300)
except DatabaseError as e: