CORD-1897: Ensure that policy_code gets updated when objects are
synchronized, or synchronization fails.
Change-Id: I917f1e8f56677796fc26e53ba44f5990fc435d51
diff --git a/xos/synchronizers/new_base/event_loop.py b/xos/synchronizers/new_base/event_loop.py
index 68398a4..a64283a 100644
--- a/xos/synchronizers/new_base/event_loop.py
+++ b/xos/synchronizers/new_base/event_loop.py
@@ -224,10 +224,10 @@
o.backend_status = "OK"
o.backend_code = 1
model_accessor.journal_object(o, "syncstep.call.save_update")
- o.save(update_fields=['enacted', 'backend_status', 'backend_register'])
+ o.save(update_fields=['enacted', 'backend_status', 'backend_register', 'backend_code'])
log.info("Saved sync object, new enacted", enacted=new_enacted)
- """ This function needs a cleanup. FIXME: Rethink backend_status, backend_register """
+ """ This function needs a cleanup. FIXME: Rethink backend_status, backend_register - Sapan """
def handle_sync_exception(self, o, e):
self.log.exception("sync step failed!", e=e, **o.tologdict())
@@ -301,6 +301,7 @@
try:
o.backend_status = o.backend_status[:1024]
o.save(update_fields=['backend_status',
+ 'backend_code',
'backend_register'],
always_update_timestamp=True)
except BaseException as e: