Method _fire

kubernetes/informer/informer.py:175–190

Execute all registered callbacks for *event_type*, passing *obj*. Callbacks are invoked sequentially on the informer's background thread. Any exception raised by an individual handler is logged and swallowed so that remaining handlers still run.

(self, event_type, obj)

        return kw

    def _fire(self, event_type, obj):
        """Execute all registered callbacks for *event_type*, passing *obj*.

        Callbacks are invoked sequentially on the informer's background thread.
        Any exception raised by an individual handler is logged and swallowed so
        that remaining handlers still run.
        """
        with self._handler_lock:
            handlers = list(self._handlers.get(event_type, []))
        for fn in handlers:
            try:
                fn(obj)
            except Exception:
                logger.exception(
                    "Exception in informer handler for %s", event_type
                )

    def _initial_list(self):
        """List all objects and populate the cache, firing ADDED/MODIFIED/DELETED events.