From 754d7c1c99e78cfa466d763688cbc5e23e7e91c8 Mon Sep 17 00:00:00 2001 From: Acribbs Date: Tue, 31 Dec 2024 18:31:02 +0100 Subject: [PATCH] updated control.py to make sure params are passed appropriately so will_run_on_lcuster returns False when --local initiated --- cgatcore/pipeline/control.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/cgatcore/pipeline/control.py b/cgatcore/pipeline/control.py index 3151a787..3e8d6e9c 100644 --- a/cgatcore/pipeline/control.py +++ b/cgatcore/pipeline/control.py @@ -28,8 +28,6 @@ import shutil import subprocess import sys -import tempfile -import time import gevent.pool import gevent.queue from ruffus.task import _pipeline_prepare_to_run, topologically_sorted_nodes, \ @@ -1263,7 +1261,12 @@ def run_workflow(args, argv=None, pipeline=None): logger.debug(f"Starting run_workflow with action {args.pipeline_action}") # Instantiate Executor to manage job tracking and cleanup - executor = Executor(job_threads=args.multiprocess, work_dir=get_params()["work_dir"]) + params = get_params() + executor = Executor( + job_threads=args.multiprocess, + work_dir=params["work_dir"], + without_cluster=params.get("without_cluster", False), + to_cluster=params.get("to_cluster", True)) executor.setup_signal_handlers() # Set up signal handlers for cleanup on interruption # Determine tasks to force-run if specified