Contents Menu Expand Light mode Dark mode Auto light/dark, in light mode Auto light/dark, in dark mode Skip to content
kuu 0.3.0
Light Logo Dark Logo
kuu 0.3.0
  • Quickstart
  • Usage
  • Integrations
  • Config
  • API Reference
    • kuu
      • kuu.persistence
      • kuu.web
        • kuu.web.fragments
        • kuu.web.dashboard
        • kuu.web.stats
        • kuu.web.api
      • kuu.transports
        • kuu.transports.rabbitmq
        • kuu.transports.redis
        • kuu.transports.nats
        • kuu.transports.postgres
      • kuu.results
        • kuu.results.postgres
        • kuu.results.redis
        • kuu.results.base
      • kuu.middleware
        • kuu.middleware.retry
        • kuu.middleware.timeout
        • kuu.middleware.logging
        • kuu.middleware.task_log
        • kuu.middleware.base
      • kuu.brokers
        • kuu.brokers.memory
        • kuu.brokers.rabbitmq
        • kuu.brokers.nats
        • kuu.brokers.redis
        • kuu.brokers.base
      • kuu.orchestrator
        • kuu.orchestrator.main
      • kuu.serializers
        • kuu.serializers.msgpack
        • kuu.serializers.json
        • kuu.serializers.pickle
        • kuu.serializers.base
      • kuu.scheduler
        • kuu.scheduler.schedule
          • kuu.scheduler.schedule.enums
          • kuu.scheduler.schedule.abc
          • kuu.scheduler.schedule.exc
        • kuu.scheduler.job
        • kuu.scheduler.scheduler
      • kuu.cli
        • kuu.cli.app
      • kuu.observability
      • kuu.contrib
        • kuu.contrib.prometheus
        • kuu.contrib.structlog
        • kuu.contrib.otel
        • kuu.contrib.dishka
      • kuu.exceptions
      • kuu.config
      • kuu.task
      • kuu.context
      • kuu.message
      • kuu.app
      • kuu.events
      • kuu.outcome
      • kuu.marshal
      • kuu.worker
      • kuu.result
      • kuu.registry
      • kuu.handle
Back to top
View this page
Edit this page

kuu.orchestrator._event_forwarder¶

Module Contents¶

Classes¶

EventForwarder

Data¶

log

API¶

kuu.orchestrator._event_forwarder.log = 'getLogger(...)'¶
class kuu.orchestrator._event_forwarder.EventForwarder(*, instance_id: str, events_sink: kuu.observability.EventsSink, events_queue: kuu._queue_drain.SyncGetQueue[object])¶

Initialization

async run(stop_event: anyio.Event) → None¶
Copyright © 2026, Alexey Pechenin <me@pyrorhythm.dev>
Made with Sphinx and @pradyunsg's Furo
On this page
  • kuu.orchestrator._event_forwarder
    • Module Contents
      • Classes
      • Data
      • API
        • log
        • EventForwarder
          • EventForwarder.run()