Index

A

ack() (kuu.brokers.base.Broker method) (kuu.brokers.memory.MemoryBroker method) (kuu.brokers.nats.NatsBroker method) (kuu.brokers.redis.RedisBroker method) acq() (kuu.transports.postgres._transport.PostgresTransport method) activity_series() (kuu.web.stats.StatsCollector method) add() (kuu.registry.Registry method) add_cwd_in_path() (in module kuu._import) add_every() (kuu.scheduler.scheduler.Scheduler method) add_schedule() (kuu.scheduler.scheduler.Scheduler method) alive (kuu.observability._protocol.WorkerSnapshot attribute) all() (kuu.observability._local.InMemoryRegistry method) (kuu.observability._protocol.InstanceRegistry method) allow_reconnect (kuu.transports.nats._opts.NatsConnectOptions attribute) annotation (kuu.observability._protocol.TaskParam attribute) app (in module kuu.cli._dashboard) (in module kuu.cli._info) (in module kuu.cli._start) (in module kuu.cli.app) (kuu.config.Settings attribute) (kuu.context.Context attribute) (kuu.web.api.DashbordAPIMixin attribute) (kuu.web.fragments.DashboardFragmentsMixin attribute)

Apr (in module kuu.scheduler.schedule.enums) April (kuu.scheduler.schedule.enums.Month attribute) args (kuu.message.Payload attribute) (kuu.observability._commands.EnqueueCmd attribute) (kuu.observability._protocol.Event attribute) (kuu.persistence._rows.RunRow attribute) (kuu.scheduler.job.BaseJob attribute) asdict() (kuu.persistence._rows.LogRow method) (kuu.persistence._rows.RunRow method) asgi_app() (in module kuu.prometheus) astuple() (kuu.persistence._rows.LogRow method) (kuu.persistence._rows.RunRow method) at (class in kuu.scheduler.schedule._impl.at) attempt (kuu.message.Message attribute) (kuu.observability._protocol.Event attribute) (kuu.observability._protocol.LogRecord attribute) (kuu.persistence._rows.LogRow attribute) (kuu.persistence._rows.RunRow attribute) Aug (in module kuu.scheduler.schedule.enums) August (kuu.scheduler.schedule.enums.Month attribute)

B

BaseJob (class in kuu.scheduler.job) between (class in kuu.scheduler.schedule._impl.between) blocking (kuu.task.Task attribute) Body (in module kuu.observability._protocol) body (kuu.observability._protocol.Envelope attribute) Broker (class in kuu.brokers.base)

broker (kuu.observability._protocol.Hello attribute) broker_key() (in module kuu.observability._broker_key) BrokerInfo (class in kuu.observability._protocol) build_app() (kuu.web.dashboard.Dashboard method) Bye (class in kuu.observability._protocol) ByeReason (in module kuu.observability._protocol)

C

canonical_json() (in module kuu.marshal) capture_args (kuu.config.PersistenceConfig attribute) ClientMetrics (class in kuu.prometheus) close() (kuu.brokers.base.Broker method) (kuu.brokers.memory.MemoryBroker method) (kuu.brokers.nats.NatsBroker method) (kuu.brokers.redis.RedisBroker method) (kuu.observability._local.MpQueueSource method) (kuu.persistence._backend.NoopBackend method) (kuu.persistence._backend.PersistenceBackend method) (kuu.persistence._postgres.PostgresBackend method) (kuu.persistence._sqlite.SqliteBackend method) (kuu.results.base.ResultBackend method) (kuu.results.postgres.PostgresResults method) (kuu.results.redis.RedisResults method) (kuu.transports.nats._transport.NatsTransport method) (kuu.transports.postgres._transport.PostgresTransport method) (kuu.transports.redis._transport.RedisTransport method) closed_cb (kuu.transports.nats._opts.NatsConnectOptions attribute) ClusterConfig (class in kuu.transports.redis._config) Cmd (class in kuu.observability._commands) CmdResponse (class in kuu.observability._commands) command_timeout (kuu.transports.postgres._config.PostgresParams attribute) concurrency (kuu.config.Settings attribute) (kuu.observability._protocol.Hello attribute) config (kuu.orchestrator.main.PresetSupervisor attribute) conn_config (kuu.transports.postgres._config.PostgresDSN attribute) (kuu.transports.postgres._config.PostgresParams property)

connect() (kuu._types.Connectable method) (kuu.brokers.base.Broker method) (kuu.brokers.memory.MemoryBroker method) (kuu.brokers.nats.NatsBroker method) (kuu.brokers.redis.RedisBroker method) (kuu.events.Signal method) (kuu.persistence._backend.NoopBackend method) (kuu.persistence._backend.PersistenceBackend method) (kuu.persistence._postgres.PostgresBackend method) (kuu.persistence._sqlite.SqliteBackend method) (kuu.results.base.ResultBackend method) (kuu.results.postgres.PostgresResults method) (kuu.results.redis.RedisResults method) (kuu.transports.nats._transport.NatsTransport method) (kuu.transports.postgres._transport.PostgresTransport method) (kuu.transports.redis._transport.RedisTransport method) connect_timeout (kuu.transports.nats._opts.NatsConnectOptions attribute) Connectable (class in kuu._types) connection_class (kuu.transports.postgres._config.PostgresParams attribute) consume() (kuu.brokers.base.Broker method) (kuu.brokers.memory.MemoryBroker method) (kuu.brokers.nats.NatsBroker method) (kuu.brokers.redis.RedisBroker method) Context (class in kuu.context) control (kuu.web.api.DashbordAPIMixin attribute) ControlPlane (class in kuu.orchestrator._control) create_backend() (in module kuu.persistence) current_msg() (in module kuu.observability._log_capture) current_task (kuu.observability._protocol.WorkerSnapshot attribute)

D

Dashboard (class in kuu.web.dashboard) dashboard (kuu.config.Settings attribute) dashboard() (in module kuu.cli._dashboard) DashboardFragmentsMixin (class in kuu.web.fragments) DashboardRunner (class in kuu.orchestrator._dashboard) DashbordAPIMixin (class in kuu.web.api) database (kuu.transports.postgres._config.PostgresParams attribute) Dec (in module kuu.scheduler.schedule.enums) December (kuu.scheduler.schedule.enums.Month attribute) DecHook (in module kuu.marshal) declare() (kuu.brokers.base.Broker method) (kuu.brokers.memory.MemoryBroker method) (kuu.brokers.nats.NatsBroker method) (kuu.brokers.redis.RedisBroker method) decode() (kuu.results.base.ResultBackend method)

default (kuu.config.Kuunfig attribute) (kuu.observability._protocol.TaskParam attribute) delay_seconds (kuu.outcome.Retry attribute) Delivery (class in kuu.brokers.base) depth (kuu.observability._protocol.QueueSnapshot attribute) direct_tls (kuu.transports.postgres._config.PostgresParams attribute) disconnect() (kuu.events.Signal method) (kuu.otel.OtelMetrics method) disconnected_cb (kuu.transports.nats._opts.NatsConnectOptions attribute) discovered_server_cb (kuu.transports.nats._opts.NatsConnectOptions attribute) dont_randomize (kuu.transports.nats._opts.NatsConnectOptions attribute) dp (kuu.brokers.nats.NatsBroker attribute) drain_timeout (kuu.transports.nats._opts.NatsConnectOptions attribute) dsn (kuu.config.PersistenceConfig attribute) (kuu.transports.postgres._config.PostgresDSN attribute)

E

elapsed (kuu.observability._protocol.Event attribute) emit() (kuu.observability._local.MpQueueSink method) (kuu.observability._log_capture.TaskLogHandler method) (kuu.observability._protocol.EventsSink method) enable (kuu.config.MetricsSettings attribute) (kuu.config.PersistenceConfig attribute) (kuu.config.SchedulerSettings attribute) (kuu.config.WatchSettings attribute) (kuu.config.WebSettings attribute) EncHook (in module kuu.marshal) encode() (kuu.results.base.ResultBackend method) enqueue() (kuu.brokers.base.Broker method) (kuu.brokers.memory.MemoryBroker method) (kuu.brokers.nats.NatsBroker method) (kuu.brokers.redis.RedisBroker method) enqueue_by_name() (kuu.app.Kuu method) enqueue_event() (kuu.persistence._worker.PersistenceWorker method) enqueue_log_batch() (kuu.persistence._worker.PersistenceWorker method) EnqueueCmd (class in kuu.observability._commands) enqueued_at (kuu.message.Message attribute) Envelope (class in kuu.observability._protocol) envelope_from_bytes() (in module kuu.observability._codec)

envelope_to_bytes() (in module kuu.observability._codec) Err (class in kuu.web.api) error (kuu.observability._commands.CmdResponse attribute) (kuu.result.Result attribute) error_cb (kuu.transports.nats._opts.NatsConnectOptions attribute) Event (class in kuu.observability._protocol) event (kuu.web.stats.EventRecord attribute) EventKind (in module kuu.observability._protocol) EventRecord (class in kuu.web.stats) Events (class in kuu.events) events_queue (kuu.orchestrator._worker.WorkerPool attribute) EventsSink (class in kuu.observability._protocol) EventsSource (class in kuu.observability._protocol) every (class in kuu.scheduler.schedule._impl.every) (kuu.scheduler.job.IntervalJob attribute) every() (kuu.app.Kuu method) exc (kuu.outcome.Fail attribute) exc_message (kuu.observability._protocol.Event attribute) (kuu.persistence._rows.RunRow attribute) exc_type (kuu.observability._protocol.Event attribute) (kuu.persistence._rows.RunRow attribute) exclude (kuu.config.WatchSettings attribute)

F

Fail (class in kuu.outcome) Feb (in module kuu.scheduler.schedule.enums) February (kuu.scheduler.schedule.enums.Month attribute) fetch_timeout (kuu.brokers.nats.NatsBroker attribute) finished_at (kuu.persistence._rows.RunRow attribute) flush() (in module kuu.observability._log_capture)

flush_timeout (kuu.transports.nats._opts.NatsConnectOptions attribute) flusher_queue_size (kuu.transports.nats._opts.NatsConnectOptions attribute) Fri (in module kuu.scheduler.schedule.enums) Friday (kuu.scheduler.schedule.enums.Weekday attribute) fromrecord() (kuu.persistence._rows.LogRow class method) (kuu.persistence._rows.RunRow class method)

G

get() (kuu.observability._local.InMemoryRegistry method) (kuu.observability._protocol.InstanceRegistry method) (kuu.registry.Registry method) (kuu.results.base.ResultBackend method) (kuu.results.postgres.PostgresResults method) (kuu.results.redis.RedisResults method)

get_type_fqn() (in module kuu._import) get_type_from_fqn() (in module kuu._import) gsslib (kuu.transports.postgres._config.PostgresParams attribute)

H

Handler (in module kuu.events) has_varargs (kuu.observability._protocol.TaskInfo attribute) headers (kuu.message.Message attribute) (kuu.scheduler.job.BaseJob attribute) Hello (class in kuu.observability._protocol)

hello (kuu.observability._protocol.InstanceInfo attribute) host (kuu.config.MetricsSettings attribute) (kuu.config.WebSettings attribute) (kuu.observability._protocol.Hello attribute) (kuu.transports.postgres._config.PostgresParams attribute) hosts (kuu.transports.redis._config.SentinelConfig attribute)

I

id (kuu.handle.TaskHandle property) (kuu.message.Message attribute) (kuu.observability._protocol.JobSnapshot attribute) (kuu.persistence._rows.RunRow attribute) (kuu.scheduler.job.BaseJob attribute) IDEMPOTENCY_HEADER (in module kuu.results.base) if_async() (in module kuu.task) import_from_modules() (in module kuu._import) import_object() (in module kuu._import) import_tasks() (in module kuu._import) in_flight (kuu.observability._protocol.QueueSnapshot attribute) in_month (class in kuu.scheduler.schedule._impl.in_month) inbox_prefix (kuu.transports.nats._opts.NatsConnectOptions attribute) info() (in module kuu.cli._info) ingest() (kuu.observability._local.InMemoryRegistry method) (kuu.observability._protocol.InstanceRegistry method) (kuu.web.stats.StatsCollector method)

ingest_envelope() (kuu.web.dashboard.Dashboard method) init_schema() (kuu.persistence._backend.NoopBackend method) (kuu.persistence._backend.PersistenceBackend method) (kuu.persistence._postgres.PostgresBackend method) (kuu.persistence._sqlite.SqliteBackend method) InMemoryRegistry (class in kuu.observability._local) install() (in module kuu.observability._log_capture) instance (kuu.observability._protocol.Envelope attribute) instance_id (kuu.observability._protocol.InstanceInfo attribute) (kuu.orchestrator.main.PresetSupervisor attribute) (kuu.persistence._rows.RunRow attribute) InstanceInfo (class in kuu.observability._protocol) InstanceRegistry (class in kuu.observability._protocol) instrument() (kuu.otel.KuuOTELInstrumentor method) IntervalJob (class in kuu.scheduler.job) InvalidReceiptType is_connected (kuu.transports.nats._transport.NatsTransport property)

J

Jan (in module kuu.scheduler.schedule.enums) January (kuu.scheduler.schedule.enums.Month attribute) jinja (kuu.web.fragments.DashboardFragmentsMixin attribute) job_id (kuu.observability._commands.RemoveJobCmd attribute) (kuu.observability._commands.TriggerJobCmd attribute) jobs (kuu.observability._protocol.State attribute) JobSnapshot (class in kuu.observability._protocol) js (kuu.brokers.nats.NatsBroker property) (kuu.transports.nats._transport.NatsTransport property)

json_decode() (kuu.marshal.Marshal method) json_encode() (kuu.marshal.Marshal method) json_encode_str() (kuu.marshal.Marshal method) JSONSerializer (class in kuu.serializers.json) Jul (in module kuu.scheduler.schedule.enums) July (kuu.scheduler.schedule.enums.Month attribute) Jun (in module kuu.scheduler.schedule.enums) June (kuu.scheduler.schedule.enums.Month attribute)

K

keep_days (kuu.config.PersistenceConfig attribute) key (kuu.handle.TaskHandle property) (kuu.observability._protocol.BrokerInfo attribute) kind (kuu.observability._protocol.Event attribute) krbsrvname (kuu.transports.postgres._config.PostgresParams attribute) kuu module Kuu (class in kuu.app) kuu._import module kuu._sig module kuu._types module kuu._util module kuu.app module kuu.brokers module kuu.brokers.base module kuu.brokers.memory module kuu.brokers.nats module kuu.brokers.redis module kuu.cli module kuu.cli._dashboard module kuu.cli._info module kuu.cli._start module kuu.cli.app module kuu.config module kuu.context module kuu.events module kuu.exceptions module kuu.handle module kuu.marshal module kuu.message module kuu.middleware module kuu.middleware.base module kuu.middleware.logging module kuu.middleware.retry module kuu.middleware.structlog module kuu.middleware.timeout module kuu.observability module kuu.observability._broker_key module kuu.observability._codec module kuu.observability._commands module kuu.observability._local module kuu.observability._log_capture module kuu.observability._protocol module kuu.observability._ws module kuu.orchestrator module kuu.orchestrator._control module kuu.orchestrator._dashboard module kuu.orchestrator._scheduler module kuu.orchestrator._watcher module kuu.orchestrator._worker module kuu.orchestrator.main module kuu.otel module kuu.outcome module kuu.persistence module kuu.persistence._backend module

kuu.persistence._postgres module kuu.persistence._rows module kuu.persistence._sqlite module kuu.persistence._worker module kuu.prometheus module kuu.registry module kuu.result module kuu.results module kuu.results.base module kuu.results.postgres module kuu.results.redis module kuu.scheduler module kuu.scheduler.job module kuu.scheduler.schedule module kuu.scheduler.schedule._impl module kuu.scheduler.schedule._impl.at module kuu.scheduler.schedule._impl.between module kuu.scheduler.schedule._impl.every module kuu.scheduler.schedule._impl.in_month module kuu.scheduler.schedule._impl.on module kuu.scheduler.schedule._impl.on_day module kuu.scheduler.schedule.abc module kuu.scheduler.schedule.enums module kuu.scheduler.schedule.exc module kuu.scheduler.scheduler module kuu.serializers module kuu.serializers.base module kuu.serializers.json module kuu.serializers.msgpack module kuu.serializers.pickle module kuu.task module kuu.transports module kuu.transports.nats module kuu.transports.nats._opts module kuu.transports.nats._transport module kuu.transports.postgres module kuu.transports.postgres._config module kuu.transports.postgres._transport module kuu.transports.redis module kuu.transports.redis._config module kuu.transports.redis._transport module kuu.web module kuu.web.api module kuu.web.dashboard module kuu.web.fragments module kuu.web.stats module kuu.worker module Kuunfig (class in kuu.config) kuunfig (kuu.orchestrator._control.ControlPlane attribute) KuuOTELInstrumentor (class in kuu.otel) kwargs (kuu.message.Payload attribute) (kuu.observability._commands.EnqueueCmd attribute) (kuu.observability._protocol.Event attribute) (kuu.persistence._rows.RunRow attribute)

L

last_seen (kuu.observability._protocol.InstanceInfo attribute) last_state (kuu.observability._protocol.InstanceInfo attribute) level (kuu.observability._protocol.LogRecord attribute) (kuu.persistence._rows.LogRow attribute) load() (kuu.config.Kuunfig class method) load_app() (in module kuu.cli._info) log (in module kuu._types) (in module kuu.cli._info) (in module kuu.cli.app) (in module kuu.events) (in module kuu.observability._ws) (in module kuu.orchestrator._control) (in module kuu.orchestrator._dashboard) (in module kuu.orchestrator._scheduler) (in module kuu.orchestrator._watcher) (in module kuu.orchestrator._worker) (in module kuu.orchestrator.main) (in module kuu.otel) (in module kuu.persistence._postgres) (in module kuu.persistence._sqlite) (in module kuu.persistence._worker) (in module kuu.results.postgres) (in module kuu.scheduler.scheduler) (in module kuu.worker)

log_level (kuu.config.PersistenceConfig attribute) LogBatch (class in kuu.observability._protocol) logger (in module kuu._import) (kuu.observability._protocol.LogRecord attribute) (kuu.persistence._rows.LogRow attribute) LoggingMiddleware (class in kuu.middleware.logging) LogRecord (class in kuu.observability._protocol) LogRow (class in kuu.persistence._rows) logs_table (kuu.config.PersistenceConfig attribute) loop (kuu.transports.postgres._config.PostgresParams attribute)

M

Mar (in module kuu.scheduler.schedule.enums) March (kuu.scheduler.schedule.enums.Month attribute) mark_worker_dead() (in module kuu.prometheus) Marshal (class in kuu.marshal) marshal (in module kuu.marshal) marshal() (kuu.serializers.base.Serializer method) (kuu.serializers.json.JSONSerializer method) (kuu.serializers.msgpack.MsgpackSerializer method) (kuu.serializers.pickle.PickleSerializer static method) marshal_types (kuu.results.base.ResultBackend attribute) matches() (kuu.scheduler.schedule._impl.at.at method) (kuu.scheduler.schedule._impl.between.between method) (kuu.scheduler.schedule._impl.every.every method) (kuu.scheduler.schedule._impl.in_month.in_month method) (kuu.scheduler.schedule._impl.on.on method) (kuu.scheduler.schedule._impl.on_day.on_day method) (kuu.scheduler.schedule.abc.Schedule method) max_attempts (kuu.message.Message attribute) (kuu.observability._protocol.TaskInfo attribute) (kuu.scheduler.job.BaseJob attribute) (kuu.task.Task attribute) max_cacheable_statement_size (kuu.transports.postgres._config.PostgresParams attribute) max_cached_statement_lifetime (kuu.transports.postgres._config.PostgresParams attribute) max_outstanding_pings (kuu.transports.nats._opts.NatsConnectOptions attribute) max_reconnect_attempts (kuu.transports.nats._opts.NatsConnectOptions attribute) max_runs (kuu.config.PersistenceConfig attribute) May (in module kuu.scheduler.schedule.enums) (kuu.scheduler.schedule.enums.Month attribute) MemoryBroker (class in kuu.brokers.memory) MemoryReceipt (class in kuu.brokers.memory) Message (class in kuu.message) message (kuu.brokers.base.Delivery attribute) (kuu.context.Context attribute) (kuu.observability._protocol.LogRecord attribute) (kuu.persistence._rows.LogRow attribute) message_id (kuu.observability._protocol.Event attribute) (kuu.observability._protocol.LogRecord attribute) (kuu.persistence._rows.LogRow attribute) (kuu.persistence._rows.RunRow attribute) metrics (kuu.config.Settings attribute) MetricsSettings (class in kuu.config) Middleware (class in kuu.middleware.base) module kuu kuu._import kuu._sig kuu._types kuu._util kuu.app kuu.brokers kuu.brokers.base kuu.brokers.memory kuu.brokers.nats kuu.brokers.redis kuu.cli kuu.cli._dashboard kuu.cli._info kuu.cli._start kuu.cli.app kuu.config kuu.context kuu.events kuu.exceptions kuu.handle kuu.marshal kuu.message kuu.middleware kuu.middleware.base kuu.middleware.logging kuu.middleware.retry kuu.middleware.structlog kuu.middleware.timeout kuu.observability kuu.observability._broker_key kuu.observability._codec kuu.observability._commands kuu.observability._local kuu.observability._log_capture kuu.observability._protocol kuu.observability._ws kuu.orchestrator kuu.orchestrator._control kuu.orchestrator._dashboard kuu.orchestrator._scheduler kuu.orchestrator._watcher kuu.orchestrator._worker kuu.orchestrator.main kuu.otel kuu.outcome kuu.persistence kuu.persistence._backend kuu.persistence._postgres kuu.persistence._rows kuu.persistence._sqlite kuu.persistence._worker kuu.prometheus kuu.registry kuu.result kuu.results kuu.results.base kuu.results.postgres kuu.results.redis kuu.scheduler kuu.scheduler.job kuu.scheduler.schedule kuu.scheduler.schedule._impl kuu.scheduler.schedule._impl.at kuu.scheduler.schedule._impl.between kuu.scheduler.schedule._impl.every kuu.scheduler.schedule._impl.in_month kuu.scheduler.schedule._impl.on kuu.scheduler.schedule._impl.on_day kuu.scheduler.schedule.abc kuu.scheduler.schedule.enums kuu.scheduler.schedule.exc kuu.scheduler.scheduler kuu.serializers kuu.serializers.base kuu.serializers.json kuu.serializers.msgpack kuu.serializers.pickle kuu.task kuu.transports kuu.transports.nats kuu.transports.nats._opts kuu.transports.nats._transport kuu.transports.postgres kuu.transports.postgres._config kuu.transports.postgres._transport kuu.transports.redis kuu.transports.redis._config kuu.transports.redis._transport kuu.web kuu.web.api kuu.web.dashboard kuu.web.fragments kuu.web.stats kuu.worker

Mon (in module kuu.scheduler.schedule.enums) Monday (kuu.scheduler.schedule.enums.Weekday attribute) Month (class in kuu.scheduler.schedule.enums) MpQueueSink (class in kuu.observability._local) MpQueueSource (class in kuu.observability._local) msgpack_decode() (kuu.marshal.Marshal method) msgpack_encode() (kuu.marshal.Marshal method) MsgpackSerializer (class in kuu.serializers.msgpack)

N

nack() (kuu.brokers.base.Broker method) (kuu.brokers.memory.MemoryBroker method) (kuu.brokers.nats.NatsBroker method) (kuu.brokers.redis.RedisBroker method) name (kuu.observability._protocol.TaskInfo attribute) (kuu.observability._protocol.TaskParam attribute) (kuu.transports.nats._opts.NatsConnectOptions attribute) names() (kuu.registry.Registry method) NatsBroker (class in kuu.brokers.nats) NatsConnectOptions (class in kuu.transports.nats._opts) NatsReceipt (in module kuu.brokers.nats) NatsTransport (class in kuu.transports.nats._transport) Next (in module kuu.middleware.base) next_after() (kuu.scheduler.schedule._impl.at.at method) (kuu.scheduler.schedule._impl.between.between method) (kuu.scheduler.schedule._impl.every.every method) (kuu.scheduler.schedule._impl.in_month.in_month method) (kuu.scheduler.schedule._impl.on.on method) (kuu.scheduler.schedule._impl.on_day.on_day method) (kuu.scheduler.schedule.abc.Schedule method)

next_run (kuu.observability._protocol.JobSnapshot attribute) (kuu.scheduler.job.BaseJob attribute) nkeys_seed (kuu.transports.nats._opts.NatsConnectOptions attribute) nkeys_seed_str (kuu.transports.nats._opts.NatsConnectOptions attribute) no_echo (kuu.transports.nats._opts.NatsConnectOptions attribute) NoopBackend (class in kuu.persistence._backend) not_before (kuu.message.Message attribute) NotConnected Nov (in module kuu.scheduler.schedule.enums) November (kuu.scheduler.schedule.enums.Month attribute)

O

object_fqn() (in module kuu._import) Oct (in module kuu.scheduler.schedule.enums) October (kuu.scheduler.schedule.enums.Month attribute) Ok (class in kuu.outcome) (class in kuu.web.api) ok (kuu.observability._commands.CmdResponse attribute) on (class in kuu.scheduler.schedule._impl.on) on_change_callback() (kuu.orchestrator._worker.WorkerPool method)

on_day (class in kuu.scheduler.schedule._impl.on_day) orchestrator (kuu.web.api.DashbordAPIMixin attribute) (kuu.web.fragments.DashboardFragmentsMixin attribute) original_func (kuu.task.Task attribute) OtelLoggingBridge (class in kuu.otel) OtelMetrics (class in kuu.otel) OtelTracingMiddleware (class in kuu.otel) Outcome (class in kuu.outcome)

P

params (kuu.observability._protocol.TaskInfo attribute) parse_pg_dsn() (in module kuu.persistence._rows) passfile (kuu.transports.postgres._config.PostgresParams attribute) password (kuu.transports.nats._opts.NatsConnectOptions attribute) (kuu.transports.postgres._config.PostgresParams attribute) path (kuu.config.WebSettings attribute) Payload (class in kuu.message) payload (kuu.message.Message attribute) pedantic (kuu.transports.nats._opts.NatsConnectOptions attribute) pending_size (kuu.transports.nats._opts.NatsConnectOptions attribute) persistence (kuu.config.Settings attribute) persistence_backend (kuu.web.api.DashbordAPIMixin attribute) (kuu.web.fragments.DashboardFragmentsMixin attribute) PersistenceBackend (class in kuu.persistence._backend) PersistenceConfig (class in kuu.config) PersistenceWorker (class in kuu.persistence._worker) phase (kuu.context.Context attribute) pickle_allowed (in module kuu.serializers.pickle) PickleSerializer (class in kuu.serializers.pickle) pid (kuu.observability._protocol.Hello attribute) (kuu.observability._protocol.WorkerSnapshot attribute)

ping_interval (kuu.transports.nats._opts.NatsConnectOptions attribute) port (kuu.config.MetricsSettings attribute) (kuu.config.WebSettings attribute) (kuu.transports.postgres._config.PostgresParams attribute) PostgresBackend (class in kuu.persistence._postgres) PostgresConfig (class in kuu.transports.postgres._config) PostgresDSN (class in kuu.transports.postgres._config) PostgresParams (class in kuu.transports.postgres._config) PostgresResults (class in kuu.results.postgres) PostgresTransport (class in kuu.transports.postgres._transport) prefetch (kuu.config.Settings attribute) preset (kuu.observability._protocol.Hello attribute) (kuu.orchestrator.main.PresetSupervisor attribute) presets (kuu.config.Kuunfig attribute) PresetSupervisor (class in kuu.orchestrator.main) processes (kuu.config.Settings attribute) (kuu.observability._protocol.Hello attribute) PROTOCOL_VERSION (in module kuu.observability._protocol) prune() (kuu.persistence._backend.NoopBackend method) (kuu.persistence._backend.PersistenceBackend method) (kuu.persistence._postgres.PostgresBackend method) (kuu.persistence._sqlite.SqliteBackend method)

Q

q() (kuu.task.Task method) query_logs() (kuu.persistence._backend.NoopBackend method) (kuu.persistence._backend.PersistenceBackend method) (kuu.persistence._postgres.PostgresBackend method) (kuu.persistence._sqlite.SqliteBackend method) query_run_attempts() (kuu.persistence._backend.NoopBackend method) (kuu.persistence._backend.PersistenceBackend method) (kuu.persistence._postgres.PostgresBackend method) (kuu.persistence._sqlite.SqliteBackend method) query_runs() (kuu.persistence._backend.NoopBackend method) (kuu.persistence._backend.PersistenceBackend method) (kuu.persistence._postgres.PostgresBackend method) (kuu.persistence._sqlite.SqliteBackend method) queue (kuu.brokers.base.Delivery attribute) (kuu.brokers.memory.MemoryReceipt attribute) (kuu.brokers.redis.RedisReceipt attribute) (kuu.message.Message attribute) (kuu.observability._protocol.Event attribute) (kuu.observability._protocol.TaskInfo attribute) (kuu.persistence._rows.RunRow attribute) (kuu.scheduler.job.BaseJob attribute)

queue_depth() (kuu.brokers.base.Broker method) (kuu.brokers.memory.MemoryBroker method) (kuu.brokers.nats.NatsBroker method) (kuu.brokers.redis.RedisBroker method) queues (kuu.config.Settings attribute) (kuu.observability._protocol.State attribute) queues() (kuu.registry.Registry method) QueueSnapshot (class in kuu.observability._protocol)

R

r (kuu.brokers.redis.RedisBroker property) (kuu.results.redis.RedisResults property) read_from_replicas (kuu.transports.redis._config.ClusterConfig attribute) reason (kuu.observability._protocol.Bye attribute) receipt (kuu.brokers.base.Delivery attribute) reconnect_time_wait (kuu.transports.nats._opts.NatsConnectOptions attribute) reconnect_to_server_handler (kuu.transports.nats._opts.NatsConnectOptions attribute) reconnected_cb (kuu.transports.nats._opts.NatsConnectOptions attribute) record_class (kuu.transports.postgres._config.PostgresParams attribute) records (kuu.observability._protocol.LogBatch attribute) RedisBroker (class in kuu.brokers.redis) RedisConfig (class in kuu.transports.redis._config) RedisReceipt (class in kuu.brokers.redis) RedisResults (class in kuu.results.redis) RedisTransport (class in kuu.transports.redis._transport) register() (kuu.marshal.Marshal method) Registry (class in kuu.registry) registry (kuu.web.api.DashbordAPIMixin attribute) (kuu.web.fragments.DashboardFragmentsMixin attribute) Reject (class in kuu.outcome) RejectErr reload_debounce (kuu.config.WatchSettings attribute) reload_delay (kuu.config.WatchSettings attribute) RemoveJobCmd (class in kuu.observability._commands) replay (kuu.results.base.ResultBackend attribute) request_id (kuu.observability._commands.CmdResponse attribute) (kuu.observability._commands.EnqueueCmd attribute) (kuu.observability._commands.RemoveJobCmd attribute) (kuu.observability._commands.TriggerJobCmd attribute)

requeue (kuu.outcome.Reject attribute) required (kuu.observability._protocol.TaskParam attribute) reset_current_msg() (in module kuu.observability._log_capture) resolve() (kuu.config.Kuunfig method) respect_gitignore (kuu.config.WatchSettings attribute) Result (class in kuu.result) result() (kuu.handle.TaskHandle method) result_key() (in module kuu.results.base) (kuu.transports.redis._transport.RedisTransport method) ResultBackend (class in kuu.results.base) Retry (class in kuu.outcome) retry_on_timeout (kuu.transports.redis._config.ClusterConfig attribute) (kuu.transports.redis._config.SentinelConfig attribute) (kuu.transports.redis._config.StandaloneConfig attribute) RetryErr RetryMiddleware (class in kuu.middleware.retry) root (kuu.config.WatchSettings attribute) run() (kuu.observability._ws.WsUplink method) (kuu.orchestrator._dashboard.DashboardRunner method) (kuu.orchestrator._scheduler.SchedulerRunner method) (kuu.orchestrator._watcher.Watcher method) (kuu.orchestrator._worker.WorkerPool method) (kuu.persistence._worker.PersistenceWorker method) (kuu.scheduler.scheduler.Scheduler method) (kuu.worker.Worker method) run_chain() (in module kuu.middleware.base) RunRow (class in kuu.persistence._rows) runs_table (kuu.config.PersistenceConfig attribute) RunStatus (in module kuu.persistence._rows)

S

Sat (in module kuu.scheduler.schedule.enums) Saturday (kuu.scheduler.schedule.enums.Weekday attribute) sched() (kuu.app.Kuu method) Schedule (class in kuu.scheduler.schedule.abc) schedule (kuu.scheduler.job.ScheduleJob attribute) schedule() (kuu.brokers.base.Broker method) (kuu.brokers.memory.MemoryBroker method) (kuu.brokers.nats.NatsBroker method) (kuu.brokers.redis.RedisBroker method) schedule_next() (kuu.scheduler.job.BaseJob method) (kuu.scheduler.job.IntervalJob method) (kuu.scheduler.job.ScheduleJob method) ScheduleError ScheduleJob (class in kuu.scheduler.job) Scheduler (class in kuu.scheduler.scheduler) scheduler (kuu.config.Settings attribute) (kuu.web.api.DashbordAPIMixin attribute) (kuu.web.fragments.DashboardFragmentsMixin attribute) scheduler_enabled (kuu.observability._protocol.Hello attribute) SchedulerRunner (class in kuu.orchestrator._scheduler) SchedulerSettings (class in kuu.config) schema (kuu.config.PersistenceConfig attribute) SCHEMA_SQL (in module kuu.results.postgres) SecurityWarning send() (kuu.events.Signal method) send_command() (kuu.orchestrator._control.ControlPlane method) SentinelConfig (class in kuu.transports.redis._config) Sep (in module kuu.scheduler.schedule.enums) September (kuu.scheduler.schedule.enums.Month attribute) seq (kuu.brokers.memory.MemoryReceipt attribute) Serializer (class in kuu.serializers.base) serializer (kuu.brokers.nats.NatsBroker attribute) (kuu.results.base.ResultBackend attribute) serve() (in module kuu.prometheus) (kuu.web.dashboard.Dashboard method) server_settings (kuu.transports.postgres._config.PostgresParams attribute) servers (kuu.brokers.nats.NatsBroker attribute) service (kuu.transports.postgres._config.PostgresParams attribute) service_name (kuu.transports.redis._config.SentinelConfig attribute) servicefile (kuu.transports.postgres._config.PostgresParams attribute) set() (kuu.results.base.ResultBackend method) (kuu.results.postgres.PostgresResults method) (kuu.results.redis.RedisResults method) set_current_msg() (in module kuu.observability._log_capture)

set_not_exists() (kuu.results.base.ResultBackend method) (kuu.results.postgres.PostgresResults method) (kuu.results.redis.RedisResults method) Settings (class in kuu.config) setup() (kuu.otel.OtelLoggingBridge method) shutdown() (in module kuu.observability._log_capture) (kuu.otel.OtelLoggingBridge method) shutdown_telemetry() (in module kuu.otel) shutdown_timeout (kuu.config.Settings attribute) sig_params() (in module kuu._sig) Signal (class in kuu.events) signature_cb (kuu.transports.nats._opts.NatsConnectOptions attribute) sink (kuu.observability._ws.WsUplink property) socket_connect_timeout (kuu.transports.redis._config.ClusterConfig attribute) (kuu.transports.redis._config.SentinelConfig attribute) (kuu.transports.redis._config.StandaloneConfig attribute) socket_timeout (kuu.transports.redis._config.ClusterConfig attribute) (kuu.transports.redis._config.SentinelConfig attribute) (kuu.transports.redis._config.StandaloneConfig attribute) sp (kuu.brokers.nats.NatsBroker attribute) SqliteBackend (class in kuu.persistence._sqlite) ssl (kuu.transports.postgres._config.PostgresParams attribute) StandaloneConfig (class in kuu.transports.redis._config) start() (kuu.orchestrator._control.ControlPlane method) (kuu.orchestrator.main.PresetSupervisor method) start_server() (kuu.web.dashboard.Dashboard method) started_at (kuu.observability._protocol.Hello attribute) (kuu.persistence._rows.RunRow attribute) State (class in kuu.observability._protocol) state (kuu.context.Context attribute) STATE_INTERVAL (in module kuu.orchestrator.main) statement_cache_size (kuu.transports.postgres._config.PostgresParams attribute) stats (kuu.web.api.DashbordAPIMixin attribute) (kuu.web.fragments.DashboardFragmentsMixin attribute) StatsCollector (class in kuu.web.stats) status (kuu.persistence._rows.RunRow attribute) (kuu.result.Result attribute) store_errors (kuu.results.base.ResultBackend attribute) stream (kuu.brokers.nats.NatsBroker attribute) stream_id (kuu.brokers.redis.RedisReceipt attribute) stream_key() (kuu.transports.redis._transport.RedisTransport method) StructlogMiddleware (class in kuu.middleware.structlog) Sun (in module kuu.scheduler.schedule.enums) Sunday (kuu.scheduler.schedule.enums.Weekday attribute)

T

target_session_attrs (kuu.transports.postgres._config.PostgresParams attribute) Task (class in kuu.task) task (kuu.context.Context attribute) (kuu.message.Message attribute) (kuu.observability._commands.EnqueueCmd attribute) (kuu.observability._protocol.Event attribute) (kuu.observability._protocol.JobSnapshot attribute) (kuu.persistence._rows.RunRow attribute) (kuu.web.stats.EventRecord attribute) task() (kuu.app.Kuu method) task_modules (kuu.config.Settings attribute) task_name (kuu.scheduler.job.BaseJob attribute) (kuu.task.Task attribute) task_queue (kuu.task.Task attribute) TaskError TaskHandle (class in kuu.handle) TaskInfo (class in kuu.observability._protocol) TaskLogHandler (class in kuu.observability._log_capture) TaskParam (class in kuu.observability._protocol) tasks (kuu.observability._protocol.Hello attribute) Thu (in module kuu.scheduler.schedule.enums) Thursday (kuu.scheduler.schedule.enums.Weekday attribute) time_elapsed (kuu.outcome.Ok attribute) (kuu.persistence._rows.RunRow attribute)

timeout (kuu.observability._protocol.TaskInfo attribute) (kuu.task.Task attribute) (kuu.transports.postgres._config.PostgresParams attribute) TimeoutMiddleware (class in kuu.middleware.timeout) title (kuu.web.fragments.DashboardFragmentsMixin attribute) tls (kuu.transports.nats._opts.NatsConnectOptions attribute) tls_handshake_first (kuu.transports.nats._opts.NatsConnectOptions attribute) tls_hostname (kuu.transports.nats._opts.NatsConnectOptions attribute) to_dict() (kuu.config.Settings method) to_naive() (in module kuu.persistence._rows) token (kuu.transports.nats._opts.NatsConnectOptions attribute) traceback (kuu.observability._protocol.Event attribute) (kuu.persistence._rows.RunRow attribute) tracer (kuu.otel.OtelTracingMiddleware property) TriggerJobCmd (class in kuu.observability._commands) ts (kuu.observability._protocol.Envelope attribute) (kuu.observability._protocol.Event attribute) (kuu.observability._protocol.LogRecord attribute) (kuu.persistence._rows.LogRow attribute) (kuu.web.stats.EventRecord attribute) ttl (kuu.results.base.ResultBackend attribute) Tue (in module kuu.scheduler.schedule.enums) Tuesday (kuu.scheduler.schedule.enums.Weekday attribute) type (kuu.observability._protocol.BrokerInfo attribute) (kuu.result.Result attribute)

U

uninstrument() (kuu.otel.KuuOTELInstrumentor method) UnknownTask unmarshal() (kuu.serializers.base.Serializer method) (kuu.serializers.json.JSONSerializer method) (kuu.serializers.msgpack.MsgpackSerializer method) (kuu.serializers.pickle.PickleSerializer static method) unregister() (kuu.marshal.Marshal method)

url (kuu.transports.redis._config.ClusterConfig attribute) (kuu.transports.redis._config.StandaloneConfig attribute) user (kuu.transports.nats._opts.NatsConnectOptions attribute) (kuu.transports.postgres._config.PostgresParams attribute) user_credentials (kuu.transports.nats._opts.NatsConnectOptions attribute) user_jwt_cb (kuu.transports.nats._opts.NatsConnectOptions attribute) utcnow() (in module kuu._util)

V

v (kuu.observability._protocol.Envelope attribute) validate_table_name() (in module kuu.persistence._rows)

value (kuu.result.Result attribute) verbose (kuu.transports.nats._opts.NatsConnectOptions attribute) version (kuu.observability._protocol.Hello attribute)

W

watch (kuu.config.Settings attribute) watch_fs (kuu.config.Settings attribute) Watcher (class in kuu.orchestrator._watcher) WatchSettings (class in kuu.config) WebSettings (class in kuu.config) Wed (in module kuu.scheduler.schedule.enums) Wednesday (kuu.scheduler.schedule.enums.Weekday attribute) Weekday (class in kuu.scheduler.schedule.enums) with_overrides() (kuu.config.Settings method) Worker (class in kuu.worker) worker() (in module kuu.cli._start) worker_pid (kuu.observability._protocol.Event attribute) (kuu.persistence._rows.RunRow attribute) WorkerEventKind (in module kuu.orchestrator._worker)

WorkerMetrics (class in kuu.prometheus) WorkerPool (class in kuu.orchestrator._worker) workers (kuu.observability._protocol.State attribute) WorkerSnapshot (class in kuu.observability._protocol) write_logs() (kuu.persistence._backend.NoopBackend method) (kuu.persistence._backend.PersistenceBackend method) (kuu.persistence._postgres.PostgresBackend method) (kuu.persistence._sqlite.SqliteBackend method) write_runs() (kuu.persistence._backend.NoopBackend method) (kuu.persistence._backend.PersistenceBackend method) (kuu.persistence._postgres.PostgresBackend method) (kuu.persistence._sqlite.SqliteBackend method) ws_connection_headers (kuu.transports.nats._opts.NatsConnectOptions attribute) WsUplink (class in kuu.observability._ws)

Z

zset_key() (kuu.transports.redis._transport.RedisTransport method)