Skip to content

Commit

Permalink
updated control.py to make sure params are passed appropriately so wi…
Browse files Browse the repository at this point in the history
…ll_run_on_lcuster returns False when --local initiated
  • Loading branch information
Acribbs committed Dec 31, 2024
1 parent 5d8ed4e commit 754d7c1
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions cgatcore/pipeline/control.py
Original file line number Diff line number Diff line change
Expand Up @@ -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, \
Expand Down Expand Up @@ -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
Expand Down

0 comments on commit 754d7c1

Please sign in to comment.