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

Add latest 2.0 fixes to main

parent b229177b
No related branches found
No related tags found
1 merge request!818Add latest 2.0 fixes to main
Pipeline #4478 passed
Pipeline: workspaces

#4480

    ......@@ -59,7 +59,9 @@ class GeneralFoundation(FoundationIF):
    # move provided files from parent directory into working directory for CASA
    for file in provided_files:
    shutil.copy(file.strip(), self.working_dir)
    stripped_file = file.strip()
    if stripped_file:
    shutil.copy(stripped_file, self.working_dir)
    self.logger.info("DATA FOUNDATION COMPLETE!")
    ......
    ......@@ -181,22 +181,26 @@ class QaPass(Action):
    @staticmethod
    def check_still_running(version: CapabilityVersion) -> bool:
    workflow_service_url = CapoConfig().settings(WORKFLOW_SETTINGS_KEY).serviceUrl
    response = requests.get(
    f"{workflow_service_url}/workflows/{version.capability.name}/requests/"
    f"{version.current_execution.current_workflow_request_id}/htcondor_id"
    )
    if json.loads(response.content.decode())["htcondor_job_id"] == "None":
    if version.current_execution.current_workflow_request_id:
    response = requests.get(
    f"{workflow_service_url}/workflows/{version.capability.name}/requests/"
    f"{version.current_execution.current_workflow_request_id}/htcondor_id"
    )
    if json.loads(response.content.decode())["htcondor_job_id"] == "None":
    return False
    return True
    else:
    return False
    return True
    @staticmethod
    def _run_qa_fail_workflow(version: CapabilityVersion):
    workflow_service_url = CapoConfig().settings(WORKFLOW_SETTINGS_KEY).serviceUrl
    logger.info(f"QA Failing version: {version.__json__()}")
    requests.post(
    f"{workflow_service_url}/workflows/{version.capability.name}/requests/"
    f"{version.current_execution.current_workflow_request_id}/qa_fail"
    )
    if version.current_execution.current_workflow_request_id:
    requests.post(
    f"{workflow_service_url}/workflows/{version.capability.name}/requests/"
    f"{version.current_execution.current_workflow_request_id}/qa_fail"
    )
    @staticmethod
    def _abort_running_execution(version: CapabilityVersion):
    ......
    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