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

random fixes

parent 3392e392
No related branches found
No related tags found
1 merge request!648random fixes
Pipeline #3644 passed
"""add qa_fail workflow templates
Revision ID: f73dff1b2e6f
Revises: acfdeb6777cb
Create Date: 2021-11-12 09:28:24.875315
"""
from alembic import op
import sqlalchemy as sa
# revision identifiers, used by Alembic.
revision = "f73dff1b2e6f"
down_revision = "acfdeb6777cb"
branch_labels = None
depends_on = None
script_content = """#!/bin/sh
set -o errexit
export HOME=$TMPDIR
./conveyor --qa-fail $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
SPOOL_DIR = {{spool_dir}}
should_transfer_files = yes
transfer_input_files = $ENV(HOME)/.ssh/condor_transfer, nraorsync://$(SBIN_PATH)/pycapo, nraorsync://$(SBIN_PATH)/conveyor, nraorsync://$(SPOOL_DIR)/metadata.json
+WantIOProxy = True
getenv = True
environment = "CAPO_PATH=/home/casa/capo"
requirements = HasLustre == True
queue
"""
def upgrade():
op.execute(
f"""
INSERT INTO workflow_templates (filename, content, workflow_name)
VALUES ('qa_fail.sh', E'{script_content}', 'qa_fail');
"""
)
op.execute(
f"""
INSERT INTO workflow_templates (filename, content, workflow_name)
VALUES ('qa_fail.condor', E'{condor}', 'qa_fail');
"""
)
def downgrade():
op.execute("DELETE FROM workflow_templates WHERE filename IN ('qa_fail.sh', 'qa_fail.condor')")
......@@ -232,12 +232,11 @@ class WorkflowService(WorkflowServiceIF):
"""
wf_request = self.info.lookup_workflow_request(request_id)
if wf_request.workflow_name == ArchiveWorkflows.DO_NOT_CALIBRATE.value:
logger.info(f"SENDING 'DO NOT CALIBRATE' MESSAGE to AAT for request #{request_id}!")
dnc_msg = ArchiveMessageArchitect(
routing_key="qa-script.fail", request=request_id, sdm_id=sdm_id
).compose_message("qa_fail")
self.archive_messenger.send_message(**dnc_msg)
logger.info(f"SENDING 'DO NOT CALIBRATE' MESSAGE to AAT for request #{request_id}!")
dnc_msg = ArchiveMessageArchitect(
routing_key="qa-script.fail", request=wf_request, sdm_id=sdm_id
).compose_message("qa_fail")
self.archive_messenger.send_message(**dnc_msg)
def execute(self, request: WorkflowRequest):
"""
......
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