WS-765: lay groundwork for QA Fail workflow

schema/versions/2e079c8ac6e3_add_qa_fail_templates.py

+"""add qa fail templates
+
+Revision ID: 2e079c8ac6e3
+Revises: b45789abd24a
+Create Date: 2021-10-28 10:00:16.586545
+
+"""
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "2e079c8ac6e3"
+down_revision = "b45789abd24a"
+branch_labels = None
+depends_on = None
+
+script_content = """#!/bin/sh
+
+set -o errexit
+export HOME=$TMPDIR
+
+./conveyor --qa_fail  --retrieve $1
+
+"""
+
+condor = """executable = qa_fail.sh
+arguments = metadata.json
+
+output = qa_fail.out
+error = qa_fail.err
+log = condor.log
+
+SBIN_PATH = /lustre/aoc/cluster/pipeline/$ENV(CAPO_PROFILE)/workspaces/sbin
+should_transfer_files = yes
+transfer_input_files = $(SBIN_PATH)/pycapo, $(SBIN_PATH)/conveyor, ./metadata.json
+
+getenv = True
+environment = "CAPO_PATH=/home/casa/capo"
+requirements = HasLustre == True
+
+queue
+
+"""
+
+
+def upgrade():
+    op.execute(
+        f"""
+        UPDATE workflow_templates
+        SET content=E'{script_content}' WHERE filename='qa_fail.sh'
+        """
+    )
+    op.execute(
+        f"""
+        UPDATE workflow_templates
+        SET content=E'{condor}' WHERE filename='qa_fail.condor'
+        """
+    )
+
+
+def downgrade():
+    op.execute("DELETE FROM workflow_templates WHERE filename IN ('qa_fail.sh', 'qa_fail.condor')")

schema/versions/b45789abd24a_add_qa_fail_workflow.py

+"""add qa fail workflow
+
+Revision ID: b45789abd24a
+Revises: 806988978ff7
+Create Date: 2021-10-28 07:34:31.798911
+
+"""
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "b45789abd24a"
+down_revision = "806988978ff7"
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    """
+    Add the QA Fail workflow
+
+    :return:
+    """
+    op.execute("INSERT INTO workflows (workflow_name) VALUES ('qa_fail')")
+
+
+def downgrade():
+    """
+    Remove the QA Fail workflow
+
+    :return:
+    """
+    op.execute("DELETE FROM workflows WHERE workflow_name='qa_fail'")