WS-508: templates for calibration ingestion workflow

schema/versions/e99b65ee2b4e_add_calibration_ingestion_workflow.py

@@ -17,7 +17,7 @@ depends_on = None
 
 
 condor_content = """executable = ingest_cal.sh
-arguments = {{request_id}} metadata.json
+arguments = metadata.json
 
 output = ingest.out
 error = ingest.err
@@ -25,7 +25,7 @@ log = condor.log
 
 SBIN_PATH = /lustre/aoc/cluster/pipeline/$ENV(CAPO_PROFILE)/workspaces/sbin
 should_transfer_files = yes
-transfer_input_files = $(SBIN_PATH)/conveyor, $(SBIN_PATH)/ingest_envoy ./metadata.json
+transfer_input_files = $(SBIN_PATH)/conveyor, $(SBIN_PATH)/ingest_envoy, $(SBIN_PATH)/calibration-table-collector.sh, ./metadata.json
 
 getenv = True
 environment = "CAPO_PATH=/home/casa/capo"
@@ -35,9 +35,9 @@ queue
 
 script_content = """#!/bin/sh
 set -o errexit
-chmod 770 .
-./conveyor --retrieve $2
-./ingest_envoy
+
+./conveyor --retrieve $1
+./ingest_envoy --ingest-cal $1
 
 """
 
@@ -65,4 +65,14 @@ def upgrade():
 
 
 def downgrade():
-    pass
+    op.execute(
+        """
+        DELETE FROM workflows WHERE workflow_name='ingest-cal'
+        """
+    )
+
+    op.execute(
+        """
+        DELETE FROM workflow_templates WHERE workflow_name='ingest-cal'
+        """
+    )