Update `dump` calls to new argument structure.

analysis/tasks/FastProd.py

@@ -216,7 +216,7 @@ class FastProd(Task, TarballExtractionMixin, HTCondorWorkflow, law.LocalWorkflow
                     logger.debug(
                         "Job successful. Writing output tarfile from directory: %s", os.getcwd()
                     )
-                    self.output().dump(os.getcwd(), filter=tarfilter)
+                    self.output().dump(os.getcwd(), formatter="tar", add_kwargs=dict(filter=tarfilter))
                 else:
                     debugfile = re.sub(
                         '.tar.gz$', '.debug.tar.gz', os.path.basename(self.output().path)
@@ -225,7 +225,7 @@ class FastProd(Task, TarballExtractionMixin, HTCondorWorkflow, law.LocalWorkflow
                         "Job failed. Writing debug tarfile: %s -> %s",
                         os.getcwd(), debugfile
                     )
-                    self.remote_target(debugfile).dump(os.getcwd())
+                    self.remote_target(debugfile).dump(os.getcwd(), formatter="tar")
 
             logger.debug("Removing temporary directory: %s", tmpdirpath)
             shutil.rmtree(tmpdirpath)

analysis/tasks/FastWarm.py

@@ -203,7 +203,7 @@ class FastWarm(Task, TarballExtractionMixin, HTCondorWorkflow, law.LocalWorkflow
                     logger.debug(
                         "Job successful. Writing output tarfile from directory: %s", os.getcwd()
                     )
-                    self.output().dump(os.getcwd(), filter=tarfilter)
+                    self.output().dump(os.getcwd(), formatter="tar", add_kwargs=dict(filter=tarfilter))
                 else:
                     debugfile = re.sub(
                         '.tar.gz$', '.debug.tar.gz', os.path.basename(self.output().path)
@@ -212,7 +212,7 @@ class FastWarm(Task, TarballExtractionMixin, HTCondorWorkflow, law.LocalWorkflow
                         "Job failed. Writing debug tarfile: %s -> %s",
                         os.getcwd(), debugfile
                     )
-                    self.remote_target(debugfile).dump(os.getcwd())
+                    self.remote_target(debugfile).dump(os.getcwd(), formatter="tar")
 
             logger.debug("Removing temporary directory: %s", tmpdirpath)
             shutil.rmtree(tmpdirpath)

analysis/tasks/MergeFastWarm.py

@@ -144,7 +144,7 @@ class MergeFastWarm(Task, TarballExtractionMixin, HTCondorRemoteStorageMixin):
                     logger.debug(
                         "Job successful. Writing output tarfile from directory: %s", os.getcwd()
                     )
-                    self.output().dump(os.getcwd(), filter=tarfilter)
+                    self.output().dump(os.getcwd(), formatter="tar", add_kwargs=dict(filter=tarfilter))
                 else:
                     debugfile = re.sub(
                         '.tar.gz$', '.debug.tar.gz', os.path.basename(self.output().path)
@@ -153,7 +153,7 @@ class MergeFastWarm(Task, TarballExtractionMixin, HTCondorRemoteStorageMixin):
                         "Job failed. Writing debug tarfile: %s -> %s",
                         os.getcwd(), debugfile
                     )
-                    self.remote_target(debugfile).dump(os.getcwd())
+                    self.remote_target(debugfile).dump(os.getcwd(), formatter="tar")
 
             logger.debug("Removing temporary directory: %s", tmpdirpath)
             shutil.rmtree(tmpdirpath)

analysis/tasks/Warmup.py

@@ -200,12 +200,12 @@ class Warmup(Task, TarballExtractionMixin, HTCondorWorkflow, law.LocalWorkflow):
 
                     logger.debug("Job successful. Writing output tarfile from directory: %s", os.getcwd())
                     logger.debug("Job successful. Writing output tarfile to directory: %s", self.output().path)
-                    self.output().dump(os.getcwd(), filter=tarfilter)
+                    self.output().dump(os.getcwd(), formatter="tar", add_kwargs=dict(filter=tarfilter))
                 else:
                     if self.htcondor_remote_storage:
                         debugfile = re.sub('.tar.gz$', '.debug.tar.gz', os.path.basename(self.output().path))
                         logger.debug("Job failed. Writing debug tarfile: %s -> %s", os.getcwd(), debugfile)
-                        self.remote_target(debugfile).dump(os.getcwd())
+                        self.remote_target(debugfile).dump(os.getcwd(), formatter="tar")
 
             logger.debug("Removing temporary directory: %s", tmpdirpath)
             shutil.rmtree(tmpdirpath)