From 94670581c4bb058f5009c519b3f9800715f9bb49 Mon Sep 17 00:00:00 2001
From: Giorgos Korfiatis <gkorf@grnet.gr>
Date: Wed, 6 May 2015 14:59:33 +0300
Subject: [PATCH] pep8 fixes
---
agkyra/agkyra/syncer/pithos_client.py | 2 +-
agkyra/agkyra/syncer/syncer.py | 3 +--
2 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/agkyra/agkyra/syncer/pithos_client.py b/agkyra/agkyra/syncer/pithos_client.py
index 759990e..af63487 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 e198107..d5ebbe0 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()
--
GitLab