diff --git a/arrakis/linmos.py b/arrakis/linmos.py index b45cbecb..165c6990 100644 --- a/arrakis/linmos.py +++ b/arrakis/linmos.py @@ -358,7 +358,7 @@ def main( all_parfiles.extend(parfiles) results = linmos.map( - quote(all_parfiles), + all_parfiles, unmapped(field), unmapped(str(image)), unmapped(holofile), diff --git a/arrakis/process_spice.py b/arrakis/process_spice.py index 91e7b541..acf01ee0 100644 --- a/arrakis/process_spice.py +++ b/arrakis/process_spice.py @@ -245,9 +245,7 @@ def create_client( cluster.adapt(minimum=minimum, maximum=maximum) elif mode == "scale": cluster.scale(maximum) - # cluster.scale(36) - # cluster = LocalCluster(n_workers=10, processes=True, threads_per_worker=1, local_directory="/dev/shm",dashboard_address=f":{args.port}") client = Client(cluster) port = client.scheduler_info()["services"]["dashboard"] @@ -359,6 +357,7 @@ def main(args: configargparse.Namespace) -> None: port_forward=args.port_forward, minimum=1, maximum=256, + mode="scale", ) # Define flow