diff --git a/agkyra/agkyra/syncer/pithos_client.py b/agkyra/agkyra/syncer/pithos_client.py index 759990e2fc68213a2a3ce46f1c46f28934e02c74..af63487fb2d7fe8debd082d91ff3eec0eb10d245 100644 --- a/agkyra/agkyra/syncer/pithos_client.py +++ b/agkyra/agkyra/syncer/pithos_client.py @@ -194,7 +194,7 @@ class PithosTargetHandle(object): @handle_client_errors @give_heartbeat def pull(self, source_handle, sync_state): -# assert isinstance(source_handle, LocalfsSourceHandle) + # assert isinstance(source_handle, LocalfsSourceHandle) info = sync_state.info etag = info.get("pithos_etag") try: diff --git a/agkyra/agkyra/syncer/syncer.py b/agkyra/agkyra/syncer/syncer.py index e19810765ce1b60b9c8f7d6ce38377776e87c70a..d5ebbe0836b5e2c0c8605c048ac5dc945fbb8978 100644 --- a/agkyra/agkyra/syncer/syncer.py +++ b/agkyra/agkyra/syncer/syncer.py @@ -107,7 +107,7 @@ class FileSyncer(object): beat = hb.get(objname) if beat is not None: if utils.younger_than( - beat["tstamp"], self.settings.action_max_wait): + beat["tstamp"], self.settings.action_max_wait): logger.warning("Object '%s' already handled; " "Probe aborted." % objname) return @@ -372,7 +372,6 @@ class FileSyncer(object): time.sleep(interval) return utils.start_daemon(DecideThread) - # TODO cleanup db of objects deleted in all clients # def cleanup(self): # db = self.get_db()