Commit 94670581 authored by Giorgos Korfiatis's avatar Giorgos Korfiatis
Browse files

pep8 fixes

parent 9bf1e27b
...@@ -194,7 +194,7 @@ class PithosTargetHandle(object): ...@@ -194,7 +194,7 @@ class PithosTargetHandle(object):
@handle_client_errors @handle_client_errors
@give_heartbeat @give_heartbeat
def pull(self, source_handle, sync_state): def pull(self, source_handle, sync_state):
# assert isinstance(source_handle, LocalfsSourceHandle) # assert isinstance(source_handle, LocalfsSourceHandle)
info = sync_state.info info = sync_state.info
etag = info.get("pithos_etag") etag = info.get("pithos_etag")
try: try:
......
...@@ -107,7 +107,7 @@ class FileSyncer(object): ...@@ -107,7 +107,7 @@ class FileSyncer(object):
beat = hb.get(objname) beat = hb.get(objname)
if beat is not None: if beat is not None:
if utils.younger_than( if utils.younger_than(
beat["tstamp"], self.settings.action_max_wait): beat["tstamp"], self.settings.action_max_wait):
logger.warning("Object '%s' already handled; " logger.warning("Object '%s' already handled; "
"Probe aborted." % objname) "Probe aborted." % objname)
return return
...@@ -372,7 +372,6 @@ class FileSyncer(object): ...@@ -372,7 +372,6 @@ class FileSyncer(object):
time.sleep(interval) time.sleep(interval)
return utils.start_daemon(DecideThread) return utils.start_daemon(DecideThread)
# TODO cleanup db of objects deleted in all clients # TODO cleanup db of objects deleted in all clients
# def cleanup(self): # def cleanup(self):
# db = self.get_db() # db = self.get_db()
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment