cleanup probing

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" %

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):

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()