Function update_progress

st2common/st2common/services/workflows.py:66–81

(wf_ex_db, message, severity="info", log=True, stream=True)

def update_progress(wf_ex_db, message, severity="info", log=True, stream=True):
    if not wf_ex_db:
        return

    if log and severity in LOG_FUNCTIONS:
        LOG_FUNCTIONS[severity](
            "[%s] %s", wf_ex_db.context["st2"]["action_execution_id"], message
        )

    if stream:
        ac_svc.store_execution_output_data_ex(
            wf_ex_db.context["st2"]["action_execution_id"],
            wf_ex_db.context["st2"]["action"],
            wf_ex_db.context["st2"]["runner"],
            "%s\n" % message,
        )


def is_action_execution_under_workflow_context(ac_ex_db):