Method process

st2actions/st2actions/notifier/notifier.py:80–106

(self, execution_db)

    @CounterWithTimer(key="notifier.action.executions")
    def process(self, execution_db):
        execution_id = str(execution_db.id)
        extra = {"execution": execution_db}
        LOG.debug('Processing action execution "%s".', execution_id, extra=extra)

        # Get the corresponding liveaction record.
        liveaction_db = LiveAction.get_by_id(execution_db.liveaction["id"])

        if execution_db.status in LIVEACTION_COMPLETED_STATES:
            # If the action execution is executed under an orquesta workflow, policies for the
            # action execution will be applied by the workflow engine. A policy may affect the
            # final state of the action execution thereby impacting the state of the workflow.
            if not workflow_service.is_action_execution_under_workflow_context(
                execution_db
            ):
                with CounterWithTimer(key="notifier.apply_post_run_policies"):
                    policy_service.apply_post_run_policies(liveaction_db)

            if liveaction_db.notify:
                with CounterWithTimer(key="notifier.notify_trigger.post"):
                    self._post_notify_triggers(
                        liveaction_db=liveaction_db, execution_db=execution_db
                    )

        self._post_generic_trigger(
            liveaction_db=liveaction_db, execution_db=execution_db
        )

    def _get_execution_for_liveaction(self, liveaction):
        execution = ActionExecution.get(liveaction__id=str(liveaction.id))