Skip to content
Snippets Groups Projects
Commit 81a00a98 authored by Charlotte Hausman's avatar Charlotte Hausman
Browse files

correct condor remote execution

parent 288d6287
No related branches found
No related tags found
1 merge request!456correct condor remote execution
Pipeline #2708 passed
"""correct remote
Revision ID: 05ef3ae32823
Revises: 4a43288e7c07
Create Date: 2021-08-27 14:56:18.650168
"""
from alembic import op
import sqlalchemy as sa
# revision identifiers, used by Alembic.
revision = "05ef3ae32823"
down_revision = "4a43288e7c07"
branch_labels = None
depends_on = None
content = """executable = vlass_seci.sh
arguments = metadata.json PPR.xml
output = seci.out
error = seci.err
log = condor.log
VLASS_DIR = {{data_location}}
SBIN_PATH = /lustre/aoc/cluster/pipeline/$ENV(CAPO_PROFILE)/workspaces/sbin
should_transfer_files = yes
transfer_input_files = $(SBIN_PATH)/.matplotlib, $(SBIN_PATH)/pycapo, $(SBIN_PATH)/framework.sh, $(SBIN_PATH)/vela, $(SBIN_PATH)/casa_envoy, ./working, ./rawdata, ./products, {{profile}}.properties, ./PPR.xml, ./metadata.json
transfer_output_files = rawdata, working, products
request_memory = {{ramInGb}}
getenv = True
environment = "CAPO_PATH=."
{{#remote}}requirements = (HasLustre =!= True){{/remote}}
queue
"""
old_content = """executable = vlass_seci.sh
arguments = metadata.json PPR.xml
output = seci.out
error = seci.err
log = condor.log
VLASS_DIR = {{data_location}}
SBIN_PATH = /lustre/aoc/cluster/pipeline/$ENV(CAPO_PROFILE)/workspaces/sbin
should_transfer_files = yes
transfer_input_files = $(SBIN_PATH)/.matplotlib, $(SBIN_PATH)/pycapo, $(SBIN_PATH)/framework.sh, $(SBIN_PATH)/vela, $(SBIN_PATH)/casa_envoy, ./working, ./rawdata, ./products, {{profile}}.properties, ./PPR.xml, ./metadata.json
transfer_output_files = rawdata, working, products
request_memory = {{ramInGb}}
getenv = True
environment = "CAPO_PATH=."
{{#remote}}.requirements = NRAO_TRANSFER_HOST == "gibson-10g2"{{/remote}}
queue
"""
def upgrade():
op.exucute(
f"""
UPDATE workflow_templates
SET content=E'{content}' WHERE filename='vlass_seci.condor'
"""
)
def downgrade():
op.exucute(
f"""
UPDATE workflow_templates
SET content=E'{old_content}' WHERE filename='vlass_seci.condor'
"""
)
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment