diff --git a/sgains/executor.py b/sgains/executor.py index b9fb032..d1bb81f 100644 --- a/sgains/executor.py +++ b/sgains/executor.py @@ -19,7 +19,7 @@ def create_local_cluster(self): print("workers=", workers, " threads_per_worker=", threads_per_worker) cluster = LocalCluster( n_workers=workers, threads_per_worker=threads_per_worker, - dashboard_address=':28787') + dashboard_address='0.0.0.0:28787') return cluster def create_sge_cluster(self): @@ -45,7 +45,7 @@ def create_sge_cluster(self): name="sgains-tools", job_extra=job_extra, walltime='08:00:00', - dashboard_address=':28787', + dashboard_address='0.0.0.0:28787', ) cluster.adapt(minimum=workers, maximum=workers) print("SGE cluster dashboard link:", cluster.dashboard_link) diff --git a/sgains/pipelines/varbin_10x_pipeline.py b/sgains/pipelines/varbin_10x_pipeline.py index 972be64..b09cd6b 100644 --- a/sgains/pipelines/varbin_10x_pipeline.py +++ b/sgains/pipelines/varbin_10x_pipeline.py @@ -258,6 +258,7 @@ def process_cell_reads(self, cell_id): df.to_csv(outfile, sep='\t', index=False) cell_dirname = self._cell_reads_dirname(cell_id) + print(f"going to remove {cell_dirname}...") shutil.rmtree(cell_dirname) return cell_id