diff --git a/agkyra/agkyra/syncer/localfs_client.py b/agkyra/agkyra/syncer/localfs_client.py index 83795505583e3cd90b37c3f57f51d9fec6c8e430..b12fcdd2d126577a965c8bf3c2d0b8570561f4de 100644 --- a/agkyra/agkyra/syncer/localfs_client.py +++ b/agkyra/agkyra/syncer/localfs_client.py @@ -505,9 +505,7 @@ class LocalfsFileClient(FileClient): final_part = parts[-1] return exclude_pattern.match(final_part) - def start_probing_file(self, objname, old_state, ref_state, - assumed_info=None, - callback=None): + def start_probing_file(self, objname, old_state, ref_state, callback=None): cached_info = self.probe_candidates.pop(objname) if self.exclude_file(objname): logger.warning("Ignoring probe archive: %s, object: %s" % diff --git a/agkyra/agkyra/syncer/pithos_client.py b/agkyra/agkyra/syncer/pithos_client.py index 24d1c0fa5818dcb771a5ce3588e5cd91bafbe3ed..42bbf14b7b6126e80d4ae24df44f4833b5488933 100644 --- a/agkyra/agkyra/syncer/pithos_client.py +++ b/agkyra/agkyra/syncer/pithos_client.py @@ -325,9 +325,7 @@ class PithosFileClient(FileClient): PITHOS_TYPE: p_type, } - def start_probing_file(self, objname, old_state, ref_state, - assumed_info=None, - callback=None): + def start_probing_file(self, objname, old_state, ref_state, callback=None): info = old_state.info cached_info = self.probe_candidates.pop(objname) if exclude_pattern.match(objname): diff --git a/agkyra/agkyra/syncer/syncer.py b/agkyra/agkyra/syncer/syncer.py index d5ebbe0836b5e2c0c8605c048ac5dc945fbb8978..efcedfc0be36baad1b63f6e33a693c5936b45368 100644 --- a/agkyra/agkyra/syncer/syncer.py +++ b/agkyra/agkyra/syncer/syncer.py @@ -97,7 +97,7 @@ class FileSyncer(object): return self.messager.get(block=block) @transaction() - def probe_file(self, archive, objname, assumed_info=None): + def probe_file(self, archive, objname): logger.info("Probing archive: %s, object: '%s'" % (archive, objname)) db = self.get_db() client = self.clients[archive] @@ -116,7 +116,6 @@ class FileSyncer(object): "object: '%s'" % (archive, objname)) return client.start_probing_file(objname, db_state, ref_state, - assumed_info=assumed_info, callback=self.update_file_state) @transaction()