diff --git a/agkyra/agkyra/syncer/messaging.py b/agkyra/agkyra/syncer/messaging.py index 541a0cba7941e5b18d8ba965738454771e774514..6558e5b5cdbf03fcf6204d46f8c320b3081ce901 100644 --- a/agkyra/agkyra/syncer/messaging.py +++ b/agkyra/agkyra/syncer/messaging.py @@ -50,7 +50,7 @@ class AckSyncMessage(Message): self.objname = kwargs["objname"] self.archive = kwargs["archive"] self.serial = kwargs["serial"] - self.logger.info("Acking archive: %s, object: '%s', serial: %s" % + self.logger.info("Acked archive: %s, object: '%s', serial: %s" % (self.archive, self.objname, self.serial)) diff --git a/agkyra/agkyra/syncer/syncer.py b/agkyra/agkyra/syncer/syncer.py index 07c5cda45774d356513a4775efcf86ff9b6a735e..08349231e44c9f8a29e430c9a03b088085e2f27a 100644 --- a/agkyra/agkyra/syncer/syncer.py +++ b/agkyra/agkyra/syncer/syncer.py @@ -235,17 +235,25 @@ class FileSyncer(object): # here we could do any checks needed on the old state, # perhaps triggering a probe - @transaction() def ack_file_sync(self, synced_source_state, synced_target_state): - db = self.get_db() + self._ack_file_sync(synced_source_state, synced_target_state) serial = synced_source_state.serial objname = synced_source_state.objname - source = synced_source_state.archive target = synced_target_state.archive msg = messaging.AckSyncMessage( archive=target, objname=objname, serial=serial, logger=logger) self.messager.put(msg) + + @transaction() + def _ack_file_sync(self, synced_source_state, synced_target_state): + db = self.get_db() + serial = synced_source_state.serial + objname = synced_source_state.objname + source = synced_source_state.archive + target = synced_target_state.archive + logger.info("Acking archive: %s, object: '%s', serial: %s" % + (target, objname, serial)) decision_state = db.get_state(self.DECISION, objname) sync_state = db.get_state(self.SYNC, objname)