diff --git a/agkyra/agkyra/syncer/localfs_client.py b/agkyra/agkyra/syncer/localfs_client.py index b12fcdd2d126577a965c8bf3c2d0b8570561f4de..bd948c42ae2ceb13a84aed3233bf5cad23c76180 100644 --- a/agkyra/agkyra/syncer/localfs_client.py +++ b/agkyra/agkyra/syncer/localfs_client.py @@ -526,7 +526,7 @@ class LocalfsFileClient(FileClient): def prepare_target(self, target_state): return LocalfsTargetHandle(self.settings, target_state) - def notifier(self, callback=None): + def notifier(self): def handle_path(path): rel_path = os.path.relpath(path, start=self.ROOTPATH) objname = utils.to_standard_sep(rel_path) diff --git a/agkyra/agkyra/syncer/pithos_client.py b/agkyra/agkyra/syncer/pithos_client.py index 42bbf14b7b6126e80d4ae24df44f4833b5488933..ac573baeef182f276597850b50cad2db1016ebd7 100644 --- a/agkyra/agkyra/syncer/pithos_client.py +++ b/agkyra/agkyra/syncer/pithos_client.py @@ -296,7 +296,7 @@ class PithosFileClient(FileClient): (last_modified, candidates)) return candidates - def notifier(self, callback=None): + def notifier(self): interval = self.settings.pithos_list_interval class PollPithosThread(utils.StoppableThread): def run_body(this): diff --git a/agkyra/agkyra/syncer/syncer.py b/agkyra/agkyra/syncer/syncer.py index efcedfc0be36baad1b63f6e33a693c5936b45368..fd4c9a2716d61206764d4c1e901ebfa94a918751 100644 --- a/agkyra/agkyra/syncer/syncer.py +++ b/agkyra/agkyra/syncer/syncer.py @@ -68,8 +68,7 @@ class FileSyncer(object): for signature, client in self.clients.iteritems(): notifier = self.notifiers.get(signature) if not self.thread_is_active(notifier): - self.notifiers[signature] = \ - client.notifier(callback=self.probe_file) + self.notifiers[signature] = client.notifier() else: logger.info("Notifier %s already up" % signature)