Function update_execution_records

st2common/st2common/services/workflows.py:1396–1482

(
    wf_ex_db,
    conductor,
    update_lv_ac_on_statuses=None,
    pub_wf_ex=False,
    pub_lv_ac=True,
    pub_ac_ex=True,
)

def update_execution_records(
    wf_ex_db,
    conductor,
    update_lv_ac_on_statuses=None,
    pub_wf_ex=False,
    pub_lv_ac=True,
    pub_ac_ex=True,
):
    # If the workflow execution is completed, then render the workflow output.
    if conductor.get_workflow_status() in statuses.COMPLETED_STATUSES:
        conductor.render_workflow_output()

    # Determine if workflow status has changed.
    wf_old_status = wf_ex_db.status
    wf_ex_db.status = conductor.get_workflow_status()
    status_changed = wf_old_status != wf_ex_db.status

    if status_changed:
        msg = 'Updating workflow execution from status "%s" to "%s".'
        update_progress(wf_ex_db, msg % (wf_old_status, wf_ex_db.status))

    # Update timestamp and output if workflow is completed.
    if wf_ex_db.status in statuses.COMPLETED_STATUSES:
        wf_ex_db.end_timestamp = date_utils.get_datetime_utc_now()
        wf_ex_db.output = conductor.get_workflow_output()

    # Update task flow and other attributes.
    wf_ex_db.errors = copy.deepcopy(conductor.errors)
    wf_ex_db.state = conductor.workflow_state.serialize()

    # Write changes to the database.
    wf_ex_db = wf_db_access.WorkflowExecution.update(wf_ex_db, publish=pub_wf_ex)

    # Return if workflow execution status is not specified in update_lv_ac_on_statuses.
    if (
        isinstance(update_lv_ac_on_statuses, list)
        and wf_ex_db.status not in update_lv_ac_on_statuses
    ):
        return

    # Update the corresponding liveaction and action execution for the workflow.
    wf_ac_ex_db = ex_db_access.ActionExecution.get_by_id(wf_ex_db.action_execution)
    wf_lv_ac_db = action_utils.get_liveaction_by_id(wf_ac_ex_db.liveaction["id"])

    # Gather result for liveaction and action execution.
    result = {"output": wf_ex_db.output or None}

    if wf_ex_db.status in statuses.ABENDED_STATUSES:
        result["errors"] = wf_ex_db.errors

        if wf_ex_db.errors:
            msg = "Workflow execution completed with errors."
            update_progress(wf_ex_db, msg, severity="error")

            for wf_ex_error in wf_ex_db.errors:
                update_progress(wf_ex_db, wf_ex_error, severity="error")

    # Sync update with corresponding liveaction and action execution.