Update arguments #845

Signed-off-by: Jono Yang <jyang@nexb.com>

Author: JonoYang

minecode_pipelines/pipelines/mine_alpine.py

@@ -40,7 +40,7 @@ def steps(cls):
 
     def mine_and_publish_alpine_packageurls(self):
         alpine.mine_and_publish_alpine_packageurls(
-            data_cluster=self.data_cluster,
+            data_clusters=self.data_clusters,
             checked_out_repos=self.checked_out_repos,
             working_path=self.working_path,
             commit_msg_func=self.commit_message,

minecode_pipelines/pipelines/mine_composer.py

@@ -79,7 +79,7 @@ def mine_and_publish_packageurls(self):
         _mine_and_publish_packageurls(
             packageurls=self.mine_packageurls(),
             total_package_count=self.packages_count(),
-            data_cluster=self.data_cluster,
+            data_clusters=self.data_clusters,
             checked_out_repos=self.checked_out_repos,
             working_path=self.working_path,
             append_purls=self.append_purls,

minecode_pipelines/pipelines/mine_debian.py

@@ -42,7 +42,7 @@ def steps(cls):
             cls.create_federatedcode_working_dir,
             cls.fetch_federation_config,
             cls.fetch_checkpoint_and_debian_index,
-            cls.mine_and_publish_alpine_packageurls,
+            cls.mine_and_publish_debian_packageurls,
             cls.save_check_point,
             cls.delete_working_dir,
         )
@@ -62,13 +62,13 @@ def fetch_checkpoint_and_debian_index(self):
         self.log(f"last_checkpoint: {self.last_checkpoint}")
         self.debian_collector = debian.DebianCollector(logger=self.log)
 
-    def mine_and_publish_alpine_packageurls(self):
+    def mine_and_publish_debian_packageurls(self):
         _mine_and_publish_packageurls(
             packageurls=self.debian_collector.get_packages(
                 previous_index_last_modified_date=self.last_checkpoint,
             ),
             total_package_count=None,
-            data_cluster=self.data_cluster,
+            data_clusters=self.data_clusters,
             checked_out_repos=self.checked_out_repos,
             working_path=self.working_path,
             append_purls=self.append_purls,

minecode_pipelines/pipes/alpine.py

@@ -546,7 +546,7 @@ def get_package_from_index(self, apkindex_url, logger=None):
 
 
 def mine_and_publish_alpine_packageurls(
-    data_cluster,
+    data_clusters,
     checked_out_repos,
     working_path,
     commit_msg_func,
@@ -568,7 +568,7 @@ def mine_and_publish_alpine_packageurls(
         _mine_and_publish_packageurls(
             packageurls=alpine_collector.get_package_from_index(index),
             total_package_count=None,
-            data_cluster=data_cluster,
+            data_clusters=data_clusters,
             checked_out_repos=checked_out_repos,
             working_path=working_path,
             append_purls=True,