diff --git a/shared/workspaces/alembic/versions/61cbcd1d83f7_mark4_import_workflow.py b/shared/workspaces/alembic/versions/61cbcd1d83f7_mark4_import_workflow.py index f7e4bdaaf3fc0892d879a4b297bda3210c95041f..547dbe0096e47899ccec60a863f6d418ce609093 100644 --- a/shared/workspaces/alembic/versions/61cbcd1d83f7_mark4_import_workflow.py +++ b/shared/workspaces/alembic/versions/61cbcd1d83f7_mark4_import_workflow.py @@ -24,15 +24,12 @@ output = import.out error = import.err log = condor.log -SBIN_PATH = /lustre/aoc/cluster/pipeline/$ENV(CAPO_PROFILE)/workspaces/sbin -SPOOL_DIR = {{spool_dir}} -should_transfer_files = yes -transfer_input_files = $ENV(HOME)/.ssh/condor_transfer, nraorsync://$(SBIN_PATH)/pycapo, $(SBIN_PATH)/mark4_import +should_transfer_files = NO +WantIOProxy = True - request_memory = {{ramInGb}} getenv = True environment = "CAPO_PATH=/home/casa/capo" +requirements = HasLustre == True queue @@ -41,7 +38,9 @@ queue mk_four_import_sh = """#!/bin/sh set -o errexit -./mark4_import +BIN_PATH=/users/vlapipe/workflows/$CAPO_PROFILE/bin + +${BIN_PATH}/mark4_import """ @@ -49,7 +48,7 @@ set -o errexit def upgrade(): op.execute( f""" - INSERT INTO workflows (workflow_name) VALUES (E'{wf_name}') + INSERT INTO workflows (workflow_name, requires_lustre) VALUES (E'{wf_name}', true) """ )