Method fire_event

salt/utils/event.py:893–939

Send a single event into the publisher with payload dict "data" and event identifier "tag" The default is 1000 ms

(self, data, tag, timeout=1000)

            cb(None)

    def fire_event(self, data, tag, timeout=1000):
        """
        Send a single event into the publisher with payload dict "data" and
        event identifier "tag"

        The default is 1000 ms
        """
        if self.opts.get("subproxy", False):
            data["proxy_target"] = self.opts["id"]

        if not str(tag):  # no empty tags allowed
            raise ValueError("Empty tag.")

        if not isinstance(data, MutableMapping):  # data must be dict
            raise ValueError(f"Dict object expected, not '{data}'.")

        if not self.cpush:
            if timeout is not None:
                timeout_s = float(timeout) / 1000
            else:
                timeout_s = None
            if not self.connect_pull(timeout=timeout_s):
                return False

        data["_stamp"] = datetime.datetime.now(datetime.timezone.utc).isoformat()
        salt.utils.tracing.inject(data)
        salt.utils.metrics.counter(
            "salt.events.fired",
            description="Events placed on the salt event bus.",
        ).add(1, attributes={"tag_prefix": _event_tag_prefix(tag)})
        event = self.pack(tag, data, max_size=self.opts["max_event_size"])
        msg = salt.utils.stringutils.to_bytes(event, "utf-8")
        if self._run_io_loop_sync:
            try:
                self.pusher.publish(msg)
            except Exception as exc:  # pylint: disable=broad-except
                log.debug(
                    "Publisher send failed with exception: %s",
                    exc,
                    exc_info_on_loglevel=logging.DEBUG,
                )
                raise
        else:
            task = self.io_loop.create_task(self.pusher.publish(msg))
            self._publish_tasks.add(task)
            task.add_done_callback(self._publish_tasks.discard)
        return True

    def fire_master(self, data, tag, timeout=1000):
        """'