Function invoke_post_run

st2common/st2common/runners/utils.py:191–245

(liveaction_db, action_db=None)

def invoke_post_run(liveaction_db, action_db=None):
    # NOTE: This import has intentionally been moved here to avoid massive performance overhead
    # (1+ second) for other functions inside this module which don't need to use those imports.
    from st2common.runners import base as runners
    from st2common.util import action_db as action_db_utils
    from st2common.content import utils as content_utils

    LOG.info("Invoking post run for action execution %s.", liveaction_db.id)

    # Identify action and runner.
    if not action_db:
        action_db = action_db_utils.get_action_by_ref(liveaction_db.action)

    if not action_db:
        LOG.error(
            "Unable to invoke post run. Action %s no longer exists.",
            liveaction_db.action,
        )
        return

    LOG.info(
        "Action execution %s runs %s of runner type %s.",
        liveaction_db.id,
        action_db.name,
        action_db.runner_type["name"],
    )

    # Get instance of the action runner and related configuration.
    runner_type_db = action_db_utils.get_runnertype_by_name(
        action_db.runner_type["name"]
    )

    runner = runners.get_runner(name=runner_type_db.name)

    entry_point = content_utils.get_entry_point_abs_path(
        pack=action_db.pack, entry_point=action_db.entry_point
    )

    libs_dir_path = content_utils.get_action_libs_abs_path(
        pack=action_db.pack, entry_point=action_db.entry_point
    )

    # Configure the action runner.
    runner.runner_type_db = runner_type_db
    runner.action = action_db
    runner.action_name = action_db.name
    runner.liveaction = liveaction_db
    runner.liveaction_id = str(liveaction_db.id)
    runner.entry_point = entry_point
    runner.context = getattr(liveaction_db, "context", dict())
    runner.callback = getattr(liveaction_db, "callback", dict())
    runner.libs_dir_path = libs_dir_path

    # Invoke the post_run method.
    runner.post_run(liveaction_db.status, liveaction_db.result)