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

fix typo

parent a7139325
No related branches found
No related tags found
1 merge request!1115fix typo
Pipeline #7158 passed
......@@ -10,8 +10,8 @@ import sqlalchemy as sa
# revision identifiers, used by Alembic.
revision = 'af13ebf9e040'
down_revision = '1aacf11f8ba4'
revision = "af13ebf9e040"
down_revision = "1aacf11f8ba4"
branch_labels = None
depends_on = None
......@@ -52,7 +52,7 @@ SBIN_PATH = /lustre/aoc/cluster/pipeline/$ENV(CAPO_PROFILE)/workspaces/sbin
PIMS_PATH = /lustre/aoc/cluster/pipeline/vlass_{{vlass_env}}/workspaces/bin
SPOOL_DIR = {{data_location}}
should_transfer_files = yes
transfer_input_files = $ENV(HOME)/.ssh/condor_transfer, nraorsync://$(SBIN_PATH)/pycapo, nraorysnc://$(PIMS_PATH)/pimscache, nraorsync://$(SBIN_PATH)/productfetcher, nraorsync://$(SPOOL_DIR)/rawdata
transfer_input_files = $ENV(HOME)/.ssh/condor_transfer, nraorsync://$(SBIN_PATH)/pycapo, nraorsync://$(PIMS_PATH)/pimscache, nraorsync://$(SBIN_PATH)/productfetcher, nraorsync://$(SPOOL_DIR)/rawdata
when_to_transfer_output = ON_EXIT
transfer_output_files = .job.ad
+nrao_output_files = "rawdata"
......@@ -86,7 +86,7 @@ export HOME=$TMPDIR
chmod 770 .
cd rawdata/
./pimscache ln -c $1 -p $2 $3
../pimscache ln -c $1 -p $2 $3
../productfetcher --product-locator $4 --product-locator $5
cd ../
"""
......@@ -155,16 +155,25 @@ cd ../products
/lustre/aoc/cluster/pipeline/vlass_{{vlass_env}}/workspaces/bin/create-cube-component-list.sh $JOB_ID
"""
def upgrade():
op.execute(f"""update workflow_templates set content=E'{new_fetch_condor}' where filename='vlass_coarse_fetch.condor'""")
op.execute(
f"""update workflow_templates set content=E'{new_fetch_condor}' where filename='vlass_coarse_fetch.condor'"""
)
op.execute(f"""update workflow_templates set content=E'{new_fetch_sh}' where filename='vlass_coarse_fetch.sh'""")
op.execute(f"""update workflow_templates set content=E'{new_dag}' where filename='vlass_coarse.dag'""")
op.execute(f"""insert into workflow_templates (filename, content, workflow_name) VALUES ('vlass_coarse_post.condor', E'{new_post}', 'vlass_coarse')""")
op.execute(f"""insert into workflow_templates (filename, content, workflow_name) VALUES ('vlass_coarse_post.sh', E'{new_post_vlass}', 'vlass_coarse')""")
op.execute(
f"""insert into workflow_templates (filename, content, workflow_name) VALUES ('vlass_coarse_post.condor', E'{new_post}', 'vlass_coarse')"""
)
op.execute(
f"""insert into workflow_templates (filename, content, workflow_name) VALUES ('vlass_coarse_post.sh', E'{new_post_vlass}', 'vlass_coarse')"""
)
def downgrade():
op.execute(f"""update workflow_templates set content=E'{old_fetch_condor}' where filename='vlass_coarse_fetch.condor'""")
op.execute(
f"""update workflow_templates set content=E'{old_fetch_condor}' where filename='vlass_coarse_fetch.condor'"""
)
op.execute(f"""update workflow_templates set content=E'{old_fetch_sh}' where filename='vlass_coarse_fetch.sh'""")
op.execute(f"""update workflow_templates set content=E'{old_dag}' where filename='vlass_coarse.dag'""")
op.execute(f"""delete from workflow_templates where filename='vlass_coarse_post.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