Index _ | A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | V | W _ __init__() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.config.SQLAlchemyBackendConfig method) (litestar_queues.backends.advanced_alchemy.event_log.AdvancedAlchemyQueueEventLog method) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel method) (litestar_queues.backends.advanced_alchemy.models.QueueMaintenanceModel method) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel method) (litestar_queues.backends.advanced_alchemy.models.QueueTaskReservationModel method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.memory.event_log.InMemoryQueueEventLog method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.redis.config.RedisBackendConfig method) (litestar_queues.backends.redis.event_log.RedisQueueEventLog method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig method) (litestar_queues.backends.sqlspec.config.SQLSpecWorkerWakeupConfig method) (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLog method) (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore method) (litestar_queues.backends.valkey.backend.ValkeyQueueBackend method) (litestar_queues.backends.valkey.config.ValkeyBackendConfig method) (litestar_queues.config.ExecutionBackendConfigProtocol method) (litestar_queues.config.MigrationConfiguringBackend method) (litestar_queues.config.QueueBackendConfigProtocol method) (litestar_queues.config.QueueConfig method) (litestar_queues.config.QueueNamespace method) (litestar_queues.config.TaskDependencyProvider method) (litestar_queues.config.WorkerConfig method) (litestar_queues.events.buffer.LiveEventBuffer method) (litestar_queues.events.channels_sink.ChannelsQueueEventSink method) (litestar_queues.events.config.EventDeliveryConfig method) (litestar_queues.events.config.QueueEventsConfig method) (litestar_queues.events.context.TaskBeatSink method) (litestar_queues.events.context.TaskExecutionContext method) (litestar_queues.events.history.EventHistoryConfig method) (litestar_queues.events.history.EventHistoryExtraColumn method) (litestar_queues.events.history.QueueEventLog method) (litestar_queues.events.history.QueueEventLogRecord method) (litestar_queues.events.history.QueueEventStageSummary method) (litestar_queues.events.producer.QueueEventProducer method) (litestar_queues.events.publisher.EventBufferConfig method) (litestar_queues.events.publisher.QueueEventPublisher method) (litestar_queues.events.sinks.CompositeQueueEventSink method) (litestar_queues.events.sinks.InMemoryQueueEventSink method) (litestar_queues.events.sinks.QueueEventSink method) (litestar_queues.events.stream_config.EventStreamConfig method) (litestar_queues.events.streaming.StreamMetrics method) (litestar_queues.exceptions.MissingDependencyError method) (litestar_queues.exceptions.QueueDispatchError method) (litestar_queues.exceptions.TaskIdentityTooLargeError method) (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.base.DispatchRepairResult method) (litestar_queues.execution.base.ExecutionCancelResult method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionStatus method) (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig method) (litestar_queues.execution.cloudtasks.backend.CloudTasksExecutionBackend method) (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig method) (litestar_queues.execution.kafka.backend.KafkaExecutionBackend method) (litestar_queues.execution.kafka.config.KafkaExecutionConfig method) (litestar_queues.execution.pubsub.backend.PubSubExecutionBackend method) (litestar_queues.execution.pubsub.config.PubSubExecutionConfig method) (litestar_queues.execution.rabbitmq.backend.RabbitMQExecutionBackend method) (litestar_queues.execution.rabbitmq.config.RabbitMQExecutionConfig method) (litestar_queues.execution.sqs.backend.SqsExecutionBackend method) (litestar_queues.execution.sqs.config.SqsExecutionConfig method) (litestar_queues.maintenance.QueueMaintenanceConfig method) (litestar_queues.maintenance.QueueMaintenancePhaseResult method) (litestar_queues.maintenance.QueueMaintenanceService method) (litestar_queues.maintenance.QueueMaintenanceSummary method) (litestar_queues.models.HeartbeatTouch method) (litestar_queues.models.HeartbeatTouchResult method) (litestar_queues.models.QueueBackendCapabilities method) (litestar_queues.models.QueuedTaskRecord method) (litestar_queues.models.QueueStatistics method) (litestar_queues.models.StaleTaskRecoveryResult method) (litestar_queues.models.TaskRequest method) (litestar_queues.models.TaskReservation method) (litestar_queues.observability.ObservabilityConfig method) (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) (litestar_queues.plugin.QueuePlugin method) (litestar_queues.service.QueueService method) (litestar_queues.task.RetryBackoff method) (litestar_queues.task.ScheduleConfig method) (litestar_queues.task.Task method) (litestar_queues.task.TaskResult method) (litestar_queues.worker.Worker method) A accepted() (litestar_queues.execution.base.ExecutionCancelResult class method) ack_deadline (litestar_queues.execution.pubsub.config.PubSubExecutionConfig attribute) ack_extension_interval (litestar_queues.execution.pubsub.config.PubSubExecutionConfig attribute) acquire_maintenance() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) acquire_worker_lock() (litestar_queues.backends.base.BaseQueueBackend method) acquired (litestar_queues.maintenance.QueueMaintenanceSummary attribute) actor (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.task.Task property) actor_id (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) actor_type (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) add() (litestar_queues.events.buffer.LiveEventBuffer method) add_records() (litestar_queues.backends.advanced_alchemy.service.QueueEventLogService method) AdvancedAlchemyQueueEventLog (class in litestar_queues.backends.advanced_alchemy.event_log) already_cancelled() (litestar_queues.execution.base.ExecutionCancelResult class method) amqp_url (litestar_queues.execution.rabbitmq.config.RabbitMQExecutionConfig attribute) api_endpoint (litestar_queues.execution.pubsub.config.PubSubExecutionConfig attribute) api_insecure (litestar_queues.execution.pubsub.config.PubSubExecutionConfig attribute) api_timeout (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) (litestar_queues.execution.kafka.config.KafkaExecutionConfig attribute) (litestar_queues.execution.pubsub.config.PubSubExecutionConfig attribute) (litestar_queues.execution.rabbitmq.config.RabbitMQExecutionConfig attribute) (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) args (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) args_json (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) as_metadata() (litestar_queues.task.RetryBackoff method) (litestar_queues.task.ScheduleConfig method) assign_worker() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) attempt (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.models.QueueEvent attribute) attempts_consumed() (in module litestar_queues.backends.base) audience (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) auto_native_json_columns (litestar_queues.backends.sqlspec.event_log.SpannerQueueEventLogStore attribute) B backend_name (litestar_queues.backends.advanced_alchemy.config.SQLAlchemyBackendConfig attribute) (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) (litestar_queues.config.ExecutionBackendConfigProtocol attribute) (litestar_queues.config.QueueBackendConfigProtocol attribute) (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) (litestar_queues.execution.kafka.config.KafkaExecutionConfig attribute) (litestar_queues.execution.pubsub.config.PubSubExecutionConfig attribute) (litestar_queues.execution.rabbitmq.config.RabbitMQExecutionConfig attribute) (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) BaseConsumerExecutionBackend (class in litestar_queues.execution.base) BaseExecutionBackend (class in litestar_queues.execution.base) BaseQueueBackend (class in litestar_queues.backends.base) batch_size (litestar_queues.config.WorkerConfig attribute) (litestar_queues.events.history.EventHistoryConfig attribute) (litestar_queues.events.publisher.EventBufferConfig attribute) beat() (in module litestar_queues.events.context) (litestar_queues.events.context.TaskExecutionContext method) bind_beat_sink() (in module litestar_queues.events.context) bind_correlation_id() (in module litestar_queues.observability) bind_task_context() (in module litestar_queues.events.context) bootstrap_servers (litestar_queues.execution.kafka.config.KafkaExecutionConfig attribute) buffer (litestar_queues.events.config.EventDeliveryConfig attribute) build_cloud_tasks_route() (in module litestar_queues.execution.cloudtasks.routes) build_run_job_request() (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) build_task_env() (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) C cancel_execution() (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) (litestar_queues.execution.cloudtasks.backend.CloudTasksExecutionBackend method) cancel_on_claim_loss (litestar_queues.config.WorkerConfig attribute) cancel_task() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.service.QueueService method) cancel_tasks() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) cancellation_poll_interval (litestar_queues.config.WorkerConfig attribute) CANCELLED (litestar_queues.consumer.TaskExitCode attribute) cancelled (litestar_queues.execution.cloudrun.backend.CloudRunExecutionStatus attribute) (litestar_queues.models.QueueStatistics attribute) capabilities (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend property) (litestar_queues.backends.base.BaseQueueBackend property) (litestar_queues.backends.memory.backend.InMemoryQueueBackend property) (litestar_queues.backends.redis.backend.RedisQueueBackend property) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend property) capture_correlation_id() (in module litestar_queues.observability) changed (litestar_queues.execution.base.DispatchRepairResult attribute) (litestar_queues.maintenance.QueueMaintenancePhaseResult attribute) channel (litestar_queues.backends.sqlspec.config.SQLSpecWorkerWakeupConfig attribute) channel() (litestar_queues.config.QueueNamespace method) (litestar_queues.events.producer.QueueEventProducer method) channel_authorizer (litestar_queues.events.stream_config.EventStreamConfig attribute) channel_name (litestar_queues.backends.sqlspec.config.SQLSpecWorkerWakeupConfig attribute) ChannelAuthorizer (in module litestar_queues.events.stream_config) channels (litestar_queues.events.config.QueueEventsConfig attribute) channels_backend (litestar_queues.events.channels_sink.ChannelsQueueEventSink property) ChannelsQueueEventSink (class in litestar_queues.events.channels_sink) check_execution_status() (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) CLAIM_LOST (litestar_queues.consumer.TaskExitCode attribute) claim_many() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) claim_many_with_expired() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) claim_next() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) claim_task() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.service.QueueService method) claim_task_with_expired() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) claim_tasks() (litestar_queues.service.QueueService method) cleanup_events() (litestar_queues.backends.advanced_alchemy.event_log.AdvancedAlchemyQueueEventLog method) (litestar_queues.backends.advanced_alchemy.service.QueueEventLogService method) (litestar_queues.backends.memory.event_log.InMemoryQueueEventLog method) (litestar_queues.backends.redis.event_log.RedisQueueEventLog method) (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLog method) (litestar_queues.events.history.QueueEventLog method) cleanup_terminal() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) clear() (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.memory.event_log.InMemoryQueueEventLog method) clear_execution_ref() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) clear_task_registry() (in module litestar_queues.task) client (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) (litestar_queues.execution.cloudtasks.backend.CloudTasksExecutionBackend attribute) close() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.events.channels_sink.ChannelsQueueEventSink method) (litestar_queues.events.sinks.CompositeQueueEventSink method) (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudtasks.backend.CloudTasksExecutionBackend method) (litestar_queues.execution.kafka.backend.KafkaExecutionBackend method) (litestar_queues.execution.pubsub.backend.PubSubExecutionBackend method) (litestar_queues.execution.rabbitmq.backend.RabbitMQExecutionBackend method) (litestar_queues.execution.sqs.backend.SqsExecutionBackend method) (litestar_queues.service.QueueService method) CLOUD_TASKS_BACKEND_NAME (in module litestar_queues.execution.cloudtasks.config) CLOUD_TASKS_MAX_SCHEDULE_HORIZON (in module litestar_queues.execution.cloudtasks.config) CLOUD_TASKS_PROTOCOL_VERSION (in module litestar_queues.execution.cloudtasks.config) CloudRunExecutionBackend (class in litestar_queues.execution.cloudrun.backend) CloudRunExecutionConfig (class in litestar_queues.execution.cloudrun.config) CloudRunExecutionStatus (class in litestar_queues.execution.cloudrun.backend) CloudTasksDelivery (class in litestar_queues.execution.cloudtasks.routes) CloudTasksExecutionBackend (class in litestar_queues.execution.cloudtasks.backend) CloudTasksExecutionConfig (class in litestar_queues.execution.cloudtasks.config) column_map (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) complete_task() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) completed (litestar_queues.models.QueueStatistics attribute) completed_at (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.models.QueuedTaskRecord attribute) CompositeQueueEventSink (class in litestar_queues.events.sinks) config (litestar_queues.backends.base.BaseQueueBackend attribute) (litestar_queues.execution.base.BaseExecutionBackend attribute) (litestar_queues.plugin.QueuePlugin property) (litestar_queues.service.QueueService property) configure_migrations() (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig method) (litestar_queues.config.MigrationConfiguringBackend method) consume_one() (in module litestar_queues.consumer) consumer_group (litestar_queues.execution.kafka.config.KafkaExecutionConfig attribute) consumer_options (litestar_queues.execution.kafka.config.KafkaExecutionConfig attribute) consumer_timeout_ms (litestar_queues.execution.rabbitmq.config.RabbitMQExecutionConfig attribute) coordination() (litestar_queues.config.QueueNamespace method) coordination_timeout (litestar_queues.maintenance.QueueMaintenanceConfig attribute) copy_for_task() (litestar_queues.task.ScheduleConfig method) create_event_log_store() (in module litestar_queues.backends.sqlspec.event_log) create_event_producer() (in module litestar_queues.events.producer) create_observability_runtime() (in module litestar_queues.observability) create_queue_store() (in module litestar_queues.backends.sqlspec.stores.factory) create_schema() (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) create_statements() (litestar_queues.backends.sqlspec.event_log.SpannerQueueEventLogStore method) (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore method) create_worker_service() (litestar_queues.plugin.QueuePlugin method) created_at (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueMaintenanceModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskReservationModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskReservation attribute) cron (litestar_queues.task.ScheduleConfig attribute) custom() (litestar_queues.events.channels.QueueChannels class method) D database_channel() (litestar_queues.config.QueueNamespace method) declare_queue (litestar_queues.execution.rabbitmq.config.RabbitMQExecutionConfig attribute) DEFAULT_DURATION_BUCKETS (in module litestar_queues.observability) default_publish_many() (in module litestar_queues.events.sinks) default_task_timeout (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) delay_for() (litestar_queues.task.RetryBackoff method) delayed_retry_max_ms (litestar_queues.execution.rabbitmq.config.RabbitMQExecutionConfig attribute) delayed_retry_min_ms (litestar_queues.execution.rabbitmq.config.RabbitMQExecutionConfig attribute) delayed_retry_type (litestar_queues.execution.rabbitmq.config.RabbitMQExecutionConfig attribute) delete_by_key() (litestar_queues.backends.advanced_alchemy.service.QueueTaskReservationService method) delete_events_by_ids() (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore method) delivery (litestar_queues.events.config.QueueEventsConfig attribute) delivery_name_prefix (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) dependencies (litestar_queues.config.QueueConfig property) description (litestar_queues.task.Task property) deserialize_detail() (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore method) detail (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.execution.base.ExecutionCancelResult attribute) detail_json (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) discover_tasks() (in module litestar_queues.task) dispatch() (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) (litestar_queues.execution.kafka.backend.KafkaExecutionBackend method) (litestar_queues.execution.pubsub.backend.PubSubExecutionBackend method) (litestar_queues.execution.rabbitmq.backend.RabbitMQExecutionBackend method) (litestar_queues.execution.sqs.backend.SqsExecutionBackend method) dispatch_deadline (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) dispatch_stale_after (litestar_queues.execution.kafka.config.KafkaExecutionConfig attribute) (litestar_queues.execution.pubsub.config.PubSubExecutionConfig attribute) (litestar_queues.execution.rabbitmq.config.RabbitMQExecutionConfig attribute) (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) DispatchRepairResult (class in litestar_queues.execution.base) drop_statements() (litestar_queues.backends.sqlspec.event_log.SpannerQueueEventLogStore method) (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore method) duration_buckets (litestar_queues.observability.ObservabilityConfig attribute) duration_ms (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.maintenance.QueueMaintenancePhaseResult attribute) (litestar_queues.maintenance.QueueMaintenanceSummary attribute) E enable_otel (litestar_queues.observability.ObservabilityConfig attribute) enable_prometheus (litestar_queues.observability.ObservabilityConfig attribute) enable_sqlcommenter (litestar_queues.observability.ObservabilityConfig attribute) enabled (litestar_queues.observability.QueueObservabilityRuntime attribute) (litestar_queues.observability.QueueObservabilityRuntimeProtocol attribute) end_span() (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) endpoint_url (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) enqueue() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.service.QueueService method) (litestar_queues.task.Task method) enqueue_many() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) entity (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) env_name() (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig method) env_prefix (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) environment() (litestar_queues.config.QueueNamespace method) error (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionStatus attribute) (litestar_queues.maintenance.QueueMaintenancePhaseResult attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.TaskResult property) error_sanitizer (litestar_queues.config.QueueConfig attribute) estimate_event_payload_bytes() (in module litestar_queues.events.chunking) event() (litestar_queues.events.context.TaskExecutionContext method) event_buffer_key() (in module litestar_queues.events.buffer) event_channels_state_key (litestar_queues.config.QueueConfig property) event_count (litestar_queues.events.history.QueueEventStageSummary attribute) EVENT_HISTORY_COLUMNS (in module litestar_queues.backends.sqlspec.schema) event_history_extra_columns (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) event_history_model_class (litestar_queues.backends.advanced_alchemy.config.SQLAlchemyBackendConfig attribute) event_history_table_name (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) event_history_table_name_for() (in module litestar_queues.backends.sqlspec.schema) event_id (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) event_key (litestar_queues.events.models.QueueEvent attribute) event_limit (litestar_queues.maintenance.QueueMaintenanceConfig attribute) event_publisher (litestar_queues.events.context.TaskExecutionContext attribute) event_publisher_state_key (litestar_queues.config.QueueConfig property) event_retention_rules (litestar_queues.maintenance.QueueMaintenanceConfig attribute) event_type (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) EventBufferConfig (class in litestar_queues.events.publisher) EventDeliveryConfig (class in litestar_queues.events.config) EventHistoryConfig (class in litestar_queues.events.history) EventHistoryExtraColumn (class in litestar_queues.events.history) events (litestar_queues.config.QueueConfig attribute) (litestar_queues.events.sinks.InMemoryQueueEventSink property) events_dependency_key (litestar_queues.config.QueueConfig attribute) events_for() (litestar_queues.events.sinks.InMemoryQueueEventSink method) EventStreamConfig (class in litestar_queues.events.stream_config) examined (litestar_queues.execution.base.DispatchRepairResult attribute) execute() (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) (litestar_queues.execution.immediate.ImmediateExecutionBackend method) (litestar_queues.execution.kafka.backend.KafkaExecutionBackend method) (litestar_queues.execution.local.LocalExecutionBackend method) (litestar_queues.execution.pubsub.backend.PubSubExecutionBackend method) (litestar_queues.execution.rabbitmq.backend.RabbitMQExecutionBackend method) (litestar_queues.execution.sqs.backend.SqsExecutionBackend method) execute_record() (litestar_queues.service.QueueService method) (litestar_queues.task.Task method) execution_backend (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.config.QueueConfig attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) (litestar_queues.task.Task property) execution_backend() (in module litestar_queues.execution) execution_backend_name() (in module litestar_queues.config) execution_config (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend property) (litestar_queues.execution.cloudtasks.backend.CloudTasksExecutionBackend property) (litestar_queues.execution.kafka.backend.KafkaExecutionBackend property) (litestar_queues.execution.pubsub.backend.PubSubExecutionBackend property) (litestar_queues.execution.rabbitmq.backend.RabbitMQExecutionBackend property) (litestar_queues.execution.sqs.backend.SqsExecutionBackend property) execution_profile (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) (litestar_queues.task.Task property) execution_ref (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.models.QueuedTaskRecord attribute) ExecutionBackendConfig (in module litestar_queues.config) ExecutionBackendConfigProtocol (class in litestar_queues.config) ExecutionCancelResult (class in litestar_queues.execution.base) executions_client (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend attribute) expected_retry_count (litestar_queues.models.HeartbeatTouch attribute) expire_overdue() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) expire_overdue_tasks() (litestar_queues.service.QueueService method) expired (litestar_queues.models.QueueStatistics attribute) expires_at (litestar_queues.backends.advanced_alchemy.mixins.QueueMaintenanceModelMixin attribute) (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueMaintenanceModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) expires_in (litestar_queues.task.Task property) expiry_check_interval (litestar_queues.config.WorkerConfig attribute) external_limit (litestar_queues.maintenance.QueueMaintenanceConfig attribute) extra (litestar_queues.events.history.QueueEventLogRecord attribute) extra_columns (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLog property) (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore property) (litestar_queues.events.history.EventHistoryConfig attribute) extra_env (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) extract_event_extras() (in module litestar_queues.events.history) extract_trace_context() (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) F fail_task() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) failed (litestar_queues.execution.cloudrun.backend.CloudRunExecutionStatus attribute) (litestar_queues.models.QueueStatistics attribute) (litestar_queues.models.StaleTaskRecoveryResult attribute) failed_task_ids (litestar_queues.models.StaleTaskRecoveryResult attribute) FAILURE (litestar_queues.consumer.TaskExitCode attribute) fallback_execution_backend (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) fifo (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) final_cancel_timeout (litestar_queues.config.WorkerConfig attribute) finalize_external_dispatch() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) first_event_at (litestar_queues.events.history.QueueEventStageSummary attribute) flush() (litestar_queues.events.buffer.LiveEventBuffer method) flush_buffer() (litestar_queues.events.publisher.QueueEventPublisher method) flush_events() (litestar_queues.backends.advanced_alchemy.event_log.AdvancedAlchemyQueueEventLog method) (litestar_queues.backends.memory.event_log.InMemoryQueueEventLog method) (litestar_queues.backends.redis.event_log.RedisQueueEventLog method) (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLog method) (litestar_queues.events.history.QueueEventLog method) flush_interval (litestar_queues.events.history.EventHistoryConfig attribute) (litestar_queues.events.publisher.EventBufferConfig attribute) for_model() (litestar_queues.backends.advanced_alchemy.repository.QueueEventLogRepository class method) (litestar_queues.backends.advanced_alchemy.repository.QueueTaskRepository class method) (litestar_queues.backends.advanced_alchemy.repository.QueueTaskReservationRepository class method) (litestar_queues.backends.advanced_alchemy.service.QueueEventLogService class method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskReservationService class method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService class method) from_dict() (litestar_queues.events.models.QueueEvent class method) (litestar_queues.events.models.QueueEventActor class method) (litestar_queues.events.models.QueueEventEntityRef class method) from_json() (litestar_queues.events.models.QueueEvent class method) function (litestar_queues.task.Task property) G get_current_task_context() (in module litestar_queues.events.context) get_default_service() (in module litestar_queues.task) get_event_log() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.service.QueueService method) get_event_producer() (litestar_queues.service.QueueService method) get_event_publisher() (litestar_queues.config.QueueConfig method) (litestar_queues.service.QueueService method) get_execution_backend() (in module litestar_queues.execution) (litestar_queues.config.QueueConfig method) (litestar_queues.service.QueueService method) get_execution_backend_class() (in module litestar_queues.execution) get_meter() (litestar_queues.observability.QueueObservabilityRuntime method) get_next_run() (litestar_queues.task.ScheduleConfig method) get_owner() (litestar_queues.backends.advanced_alchemy.service.QueueTaskReservationService method) get_queue_backend() (in module litestar_queues.backends) (litestar_queues.config.QueueConfig method) (litestar_queues.service.QueueService method) get_queue_backend_class() (in module litestar_queues.backends) get_scheduled_tasks() (in module litestar_queues.task) get_service() (litestar_queues.config.QueueConfig method) (litestar_queues.plugin.QueuePlugin method) get_statistics() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.service.QueueService method) get_task() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.service.QueueService method) get_task_by_key() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) get_task_identity() (litestar_queues.service.QueueService method) get_task_registry() (in module litestar_queues.task) get_tasks() (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) get_tracer() (litestar_queues.observability.QueueObservabilityRuntime method) global_channel() (litestar_queues.events.channels.QueueChannels class method) graceful_shutdown_timeout (litestar_queues.config.WorkerConfig attribute) Guard (in module litestar_queues.events.stream_config) guards (litestar_queues.events.stream_config.EventStreamConfig attribute) (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) H handler_needed (litestar_queues.models.StaleTaskRecoveryResult attribute) handler_needed_task_ids (litestar_queues.models.StaleTaskRecoveryResult attribute) hard_exit_timeout (litestar_queues.config.WorkerConfig attribute) has_identity() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) heartbeat_at (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.models.QueuedTaskRecord attribute) heartbeat_interval (litestar_queues.config.WorkerConfig attribute) (litestar_queues.events.stream_config.EventStreamConfig attribute) heartbeat_jitter_fraction (litestar_queues.config.WorkerConfig attribute) heartbeat_miss_threshold (litestar_queues.config.WorkerConfig attribute) heartbeat_pool_config (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) heartbeat_session_maker (litestar_queues.backends.advanced_alchemy.config.SQLAlchemyBackendConfig attribute) HeartbeatTouch (class in litestar_queues.models) HeartbeatTouchResult (class in litestar_queues.models) history (litestar_queues.events.config.QueueEventsConfig attribute) I id (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueMaintenanceModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskReservationModel attribute) (litestar_queues.config.WorkerConfig attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.events.models.QueueEventActor attribute) (litestar_queues.events.models.QueueEventEntityRef attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.TaskResult property) identity_key (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskReservationModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskReservationModel attribute) ImmediateExecutionBackend (class in litestar_queues.execution.immediate) include_in_schema (litestar_queues.events.stream_config.EventStreamConfig attribute) indexed (litestar_queues.events.history.EventHistoryExtraColumn attribute) initial_delay (litestar_queues.task.RetryBackoff attribute) (litestar_queues.task.ScheduleConfig attribute) initialize_schedules (litestar_queues.config.QueueConfig attribute) initialize_schedules() (litestar_queues.service.QueueService method) inject_trace_context() (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) InMemoryQueueBackend (class in litestar_queues.backends.memory.backend) InMemoryQueueEventLog (class in litestar_queues.backends.memory.event_log) InMemoryQueueEventSink (class in litestar_queues.events.sinks) insert_events_template() (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore method) interrupt_task() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.service.QueueService method) interruption_count() (in module litestar_queues.backends.base) interval (litestar_queues.task.ScheduleConfig attribute) INVALID_TASK_ID (litestar_queues.consumer.TaskExitCode attribute) is_cancelled (litestar_queues.events.context.TaskExecutionContext property) is_default (litestar_queues.config.QueueNamespace property) is_due (litestar_queues.models.QueuedTaskRecord property) is_expired (litestar_queues.models.QueuedTaskRecord property) is_external (litestar_queues.execution.base.BaseExecutionBackend property) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend property) (litestar_queues.execution.cloudtasks.backend.CloudTasksExecutionBackend property) (litestar_queues.execution.kafka.backend.KafkaExecutionBackend property) (litestar_queues.execution.pubsub.backend.PubSubExecutionBackend property) (litestar_queues.execution.rabbitmq.backend.RabbitMQExecutionBackend property) (litestar_queues.execution.sqs.backend.SqsExecutionBackend property) is_external_dispatch_reservation() (in module litestar_queues.backends.base) is_running (litestar_queues.worker.Worker property) is_terminal (litestar_queues.models.QueuedTaskRecord property) iter_all() (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) J jitter (litestar_queues.task.ScheduleConfig attribute) job_cancelled() (in module litestar_queues.exceptions) job_name (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) JobCancelledError jobs_client (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend attribute) K KafkaExecutionBackend (class in litestar_queues.execution.kafka.backend) KafkaExecutionConfig (class in litestar_queues.execution.kafka.config) key (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) (litestar_queues.models.TaskReservation attribute) (litestar_queues.task.Task property) key() (litestar_queues.config.QueueNamespace method) key_prefix (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) kwargs (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) kwargs_json (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) L last_event_at (litestar_queues.events.history.QueueEventStageSummary attribute) latest_message (litestar_queues.events.history.QueueEventStageSummary attribute) latest_sequence (litestar_queues.events.history.QueueEventStageSummary attribute) level (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) lifecycle() (litestar_queues.events.context.TaskExecutionContext method) list_completed_by_task() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) list_execution_backends() (in module litestar_queues.execution) list_pending() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) list_queue_backends() (in module litestar_queues.backends) list_running_external() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) litestar_queues.backends.advanced_alchemy.backend module litestar_queues.backends.advanced_alchemy.config module litestar_queues.backends.advanced_alchemy.event_log module litestar_queues.backends.advanced_alchemy.mixins module litestar_queues.backends.advanced_alchemy.models module litestar_queues.backends.advanced_alchemy.repository module litestar_queues.backends.advanced_alchemy.service module litestar_queues.backends.base module litestar_queues.backends.memory.backend module litestar_queues.backends.memory.event_log module litestar_queues.backends.redis.backend module litestar_queues.backends.redis.config module litestar_queues.backends.redis.event_log module litestar_queues.backends.sqlspec.backend module litestar_queues.backends.sqlspec.config module litestar_queues.backends.sqlspec.event_log module litestar_queues.backends.sqlspec.schema module litestar_queues.backends.sqlspec.stores.factory module litestar_queues.backends.valkey.backend module litestar_queues.backends.valkey.config module litestar_queues.config module litestar_queues.consumer module litestar_queues.events.buffer module litestar_queues.events.channels module litestar_queues.events.channels_sink module litestar_queues.events.chunking module litestar_queues.events.config module litestar_queues.events.context module litestar_queues.events.history module litestar_queues.events.models module litestar_queues.events.producer module litestar_queues.events.publisher module litestar_queues.events.sinks module litestar_queues.events.stream_config module litestar_queues.events.streaming module litestar_queues.exceptions module litestar_queues.execution.base module litestar_queues.execution.cloudrun.backend module litestar_queues.execution.cloudrun.config module litestar_queues.execution.cloudtasks.backend module litestar_queues.execution.cloudtasks.config module litestar_queues.execution.cloudtasks.routes module litestar_queues.execution.immediate module litestar_queues.execution.kafka.backend module litestar_queues.execution.kafka.config module litestar_queues.execution.local module litestar_queues.execution.pubsub.backend module litestar_queues.execution.pubsub.config module litestar_queues.execution.rabbitmq.backend module litestar_queues.execution.rabbitmq.config module litestar_queues.execution.sqs.backend module litestar_queues.execution.sqs.config module litestar_queues.maintenance module litestar_queues.models module litestar_queues.observability module litestar_queues.plugin module litestar_queues.service module litestar_queues.task module litestar_queues.typing module litestar_queues.worker module LiveEventBuffer (class in litestar_queues.events.buffer) load_task_modules() (in module litestar_queues.task) LocalExecutionBackend (class in litestar_queues.execution.local) location (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) log() (litestar_queues.events.context.TaskExecutionContext method) log_level (litestar_queues.task.Task property) log_success (litestar_queues.config.QueueConfig attribute) (litestar_queues.task.Task property) logger() (litestar_queues.config.QueueNamespace method) M maintenance (litestar_queues.config.QueueConfig attribute) maintenance_model_class (litestar_queues.backends.advanced_alchemy.config.SQLAlchemyBackendConfig attribute) maintenance_name (litestar_queues.config.QueueConfig property) maintenance_table_name (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) maintenance_table_name_for() (in module litestar_queues.backends.sqlspec.schema) MaintenancePhase (in module litestar_queues.maintenance) MaintenancePhaseStatus (in module litestar_queues.maintenance) manage_schema (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) manages_lifecycle (litestar_queues.events.channels_sink.ChannelsQueueEventSink property) mark_cancelled() (litestar_queues.events.context.TaskExecutionContext method) max_argument_identity_bytes (litestar_queues.config.QueueConfig attribute) max_concurrency (litestar_queues.config.WorkerConfig attribute) max_delay (litestar_queues.task.RetryBackoff attribute) max_interruptions (litestar_queues.config.WorkerConfig attribute) max_payload_bytes (litestar_queues.events.config.EventDeliveryConfig attribute) max_pending (litestar_queues.events.publisher.EventBufferConfig attribute) max_retries (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) max_schedule_horizon (litestar_queues.execution.base.BaseExecutionBackend property) (litestar_queues.execution.cloudtasks.backend.CloudTasksExecutionBackend property) memory_capacity (litestar_queues.events.history.EventHistoryConfig attribute) message (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) message_group_id (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) metadata (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) metadata() (litestar_queues.task.Task method) metadata_json (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) metadata_patch (litestar_queues.models.HeartbeatTouch attribute) meter_name (litestar_queues.observability.ObservabilityConfig attribute) meter_provider (litestar_queues.observability.ObservabilityConfig attribute) metric() (litestar_queues.config.QueueNamespace method) metric_prefix (litestar_queues.observability.ObservabilityConfig attribute) migration_directory() (in module litestar_queues.backends.sqlspec.schema) migration_paths() (in module litestar_queues.backends.sqlspec.schema) MigrationConfiguringBackend (class in litestar_queues.config) missed_task_ids (litestar_queues.models.HeartbeatTouchResult attribute) MISSING_CONFIG_FACTORY (litestar_queues.consumer.TaskExitCode attribute) MISSING_RECORD (litestar_queues.consumer.TaskExitCode attribute) MISSING_TASK_ID (litestar_queues.consumer.TaskExitCode attribute) MissingDependencyError model_class (litestar_queues.backends.advanced_alchemy.config.SQLAlchemyBackendConfig attribute) model_from_record() (litestar_queues.backends.advanced_alchemy.service.QueueEventLogService method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) module litestar_queues.backends.advanced_alchemy.backend litestar_queues.backends.advanced_alchemy.config litestar_queues.backends.advanced_alchemy.event_log litestar_queues.backends.advanced_alchemy.mixins litestar_queues.backends.advanced_alchemy.models litestar_queues.backends.advanced_alchemy.repository litestar_queues.backends.advanced_alchemy.service litestar_queues.backends.base litestar_queues.backends.memory.backend litestar_queues.backends.memory.event_log litestar_queues.backends.redis.backend litestar_queues.backends.redis.config litestar_queues.backends.redis.event_log litestar_queues.backends.sqlspec.backend litestar_queues.backends.sqlspec.config litestar_queues.backends.sqlspec.event_log litestar_queues.backends.sqlspec.schema litestar_queues.backends.sqlspec.stores.factory litestar_queues.backends.valkey.backend litestar_queues.backends.valkey.config litestar_queues.config litestar_queues.consumer litestar_queues.events.buffer litestar_queues.events.channels litestar_queues.events.channels_sink litestar_queues.events.chunking litestar_queues.events.config litestar_queues.events.context litestar_queues.events.history litestar_queues.events.models litestar_queues.events.producer litestar_queues.events.publisher litestar_queues.events.sinks litestar_queues.events.stream_config litestar_queues.events.streaming litestar_queues.exceptions litestar_queues.execution.base litestar_queues.execution.cloudrun.backend litestar_queues.execution.cloudrun.config litestar_queues.execution.cloudtasks.backend litestar_queues.execution.cloudtasks.config litestar_queues.execution.cloudtasks.routes litestar_queues.execution.immediate litestar_queues.execution.kafka.backend litestar_queues.execution.kafka.config litestar_queues.execution.local litestar_queues.execution.pubsub.backend litestar_queues.execution.pubsub.config litestar_queues.execution.rabbitmq.backend litestar_queues.execution.rabbitmq.config litestar_queues.execution.sqs.backend litestar_queues.execution.sqs.config litestar_queues.maintenance litestar_queues.models litestar_queues.observability litestar_queues.plugin litestar_queues.service litestar_queues.task litestar_queues.typing litestar_queues.worker multiplier (litestar_queues.task.RetryBackoff attribute) N name (litestar_queues.backends.advanced_alchemy.mixins.QueueMaintenanceModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueMaintenanceModel attribute) (litestar_queues.events.history.EventHistoryExtraColumn attribute) (litestar_queues.events.models.QueueEventActor attribute) (litestar_queues.events.models.QueueEventEntityRef attribute) (litestar_queues.task.Task property) names (litestar_queues.config.QueueConfig attribute) namespace (litestar_queues.config.QueueConfig attribute) native_json_columns (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) next_scheduled_at() (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) non_retryable() (in module litestar_queues.exceptions) NonRetryableError NoopQueueEventSink (class in litestar_queues.events.sinks) notify_new_task() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) notify_new_tasks() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) notify_worker_control() (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) null_heartbeats() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) O observability (litestar_queues.config.QueueConfig attribute) observability_runtime (litestar_queues.service.QueueService property) observability_runtime_state_key (litestar_queues.config.QueueConfig property) ObservabilityConfig (class in litestar_queues.observability) occurred_at (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) on_app_init() (litestar_queues.plugin.QueuePlugin method) on_cli_init() (litestar_queues.plugin.QueuePlugin method) on_connect() (litestar_queues.events.streaming.StreamMetrics method) on_dedup_drop() (litestar_queues.events.streaming.StreamMetrics method) on_denial() (litestar_queues.events.streaming.StreamMetrics method) on_disconnect() (litestar_queues.events.streaming.StreamMetrics method) on_event() (litestar_queues.events.streaming.StreamMetrics method) on_heartbeat() (litestar_queues.events.streaming.StreamMetrics method) on_stale_failure (litestar_queues.task.Task property) open() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.events.channels_sink.ChannelsQueueEventSink method) (litestar_queues.events.sinks.CompositeQueueEventSink method) (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.service.QueueService method) opt (litestar_queues.events.stream_config.EventStreamConfig attribute) OtelMeter (in module litestar_queues.typing) OtelSpan (in module litestar_queues.typing) OtelSpanKind (in module litestar_queues.typing) OtelStatus (in module litestar_queues.typing) OtelStatusCode (in module litestar_queues.typing) OtelTracer (in module litestar_queues.typing) outcome (litestar_queues.maintenance.QueueMaintenanceSummary attribute) overflow (litestar_queues.events.publisher.EventBufferConfig attribute) P package_task() (litestar_queues.config.QueueNamespace method) parameter_name() (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore method) path (litestar_queues.events.stream_config.EventStreamConfig attribute) payload (litestar_queues.events.models.QueueEvent attribute) payload_size_estimator (litestar_queues.events.config.EventDeliveryConfig attribute) pending (litestar_queues.models.QueueStatistics attribute) permits_durable_cancel (litestar_queues.execution.base.ExecutionCancelResult property) phase (litestar_queues.maintenance.QueueMaintenancePhaseResult attribute) phases (litestar_queues.maintenance.QueueMaintenanceSummary attribute) placement (litestar_queues.config.WorkerConfig attribute) poll_backoff_max (litestar_queues.config.WorkerConfig attribute) poll_backoff_multiplier (litestar_queues.config.WorkerConfig attribute) poll_interval (litestar_queues.backends.sqlspec.config.SQLSpecWorkerWakeupConfig attribute) (litestar_queues.config.WorkerConfig attribute) poll_jitter (litestar_queues.config.WorkerConfig attribute) prefix (litestar_queues.events.channels.QueueChannels attribute) priority (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) (litestar_queues.task.Task property) producer_options (litestar_queues.execution.kafka.config.KafkaExecutionConfig attribute) profiles (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) progress() (litestar_queues.events.context.TaskExecutionContext method) progress_current (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) progress_percent (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) progress_total (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) project_id (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) (litestar_queues.execution.pubsub.config.PubSubExecutionConfig attribute) prometheus_default_registry() (in module litestar_queues.typing) prometheus_registry (litestar_queues.observability.ObservabilityConfig attribute) PrometheusCounter (in module litestar_queues.typing) PrometheusGauge (in module litestar_queues.typing) PrometheusHistogram (in module litestar_queues.typing) provide_event_producer_dependency() (litestar_queues.config.QueueConfig method) provide_service_dependency() (litestar_queues.config.QueueConfig method) publish() (litestar_queues.events.channels_sink.ChannelsQueueEventSink method) (litestar_queues.events.context.TaskExecutionContext method) (litestar_queues.events.publisher.QueueEventPublisher method) (litestar_queues.events.sinks.CompositeQueueEventSink method) (litestar_queues.events.sinks.InMemoryQueueEventSink method) (litestar_queues.events.sinks.NoopQueueEventSink method) (litestar_queues.events.sinks.QueueEventSink method) publish_claim_lost() (litestar_queues.service.QueueService method) publish_event() (litestar_queues.backends.advanced_alchemy.event_log.AdvancedAlchemyQueueEventLog method) (litestar_queues.backends.memory.event_log.InMemoryQueueEventLog method) (litestar_queues.backends.redis.event_log.RedisQueueEventLog method) (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLog method) (litestar_queues.events.history.QueueEventLog method) publish_global_lifecycle (litestar_queues.events.config.EventDeliveryConfig attribute) (litestar_queues.events.publisher.QueueEventPublisher attribute) publish_many() (litestar_queues.events.channels_sink.ChannelsQueueEventSink method) (litestar_queues.events.sinks.CompositeQueueEventSink method) (litestar_queues.events.sinks.InMemoryQueueEventSink method) (litestar_queues.events.sinks.NoopQueueEventSink method) publish_queue_channel (litestar_queues.events.config.EventDeliveryConfig attribute) (litestar_queues.events.publisher.QueueEventPublisher attribute) publish_task_channel (litestar_queues.events.config.EventDeliveryConfig attribute) (litestar_queues.events.publisher.QueueEventPublisher attribute) publish_task_event() (in module litestar_queues.events.context) publish_task_log() (in module litestar_queues.events.context) publish_task_progress() (in module litestar_queues.events.context) published (litestar_queues.events.sinks.InMemoryQueueEventSink property) PubSubExecutionBackend (class in litestar_queues.execution.pubsub.backend) PubSubExecutionConfig (class in litestar_queues.execution.pubsub.config) Q query_events() (litestar_queues.backends.advanced_alchemy.event_log.AdvancedAlchemyQueueEventLog method) (litestar_queues.backends.advanced_alchemy.service.QueueEventLogService method) (litestar_queues.backends.memory.event_log.InMemoryQueueEventLog method) (litestar_queues.backends.redis.event_log.RedisQueueEventLog method) (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLog method) (litestar_queues.events.history.QueueEventLog method) queue (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) (litestar_queues.task.Task property) queue() (litestar_queues.events.channels.QueueChannels class method) (litestar_queues.events.producer.QueueEventProducer method) queue_backend (litestar_queues.config.QueueConfig attribute) queue_backend() (in module litestar_queues.backends) queue_backend_name() (in module litestar_queues.config) queue_concurrency (litestar_queues.config.WorkerConfig attribute) queue_id (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) queue_name (litestar_queues.execution.rabbitmq.config.RabbitMQExecutionConfig attribute) queue_path (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig property) queue_table_name (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) (litestar_queues.backends.sqlspec.config.SQLSpecWorkerWakeupConfig attribute) queue_url (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) QueueBackendCapabilities (class in litestar_queues.models) QueueBackendConfig (in module litestar_queues.config) QueueBackendConfigProtocol (class in litestar_queues.config) QueueChannels (class in litestar_queues.events.channels) QueueConfig (class in litestar_queues.config) QueueConfigurationError queued_at (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.models.QueuedTaskRecord attribute) QueueDispatchError QueuedTaskRecord (class in litestar_queues.models) QueueError QueueEvent (class in litestar_queues.events.models) QueueEventActor (class in litestar_queues.events.models) QueueEventBufferFull QueueEventEntityRef (class in litestar_queues.events.models) QueueEventHistoryModel (class in litestar_queues.backends.advanced_alchemy.models) QueueEventHistoryModelMixin (class in litestar_queues.backends.advanced_alchemy.mixins) QueueEventLog (class in litestar_queues.events.history) QueueEventLogRecord (class in litestar_queues.events.history) QueueEventLogRepository (class in litestar_queues.backends.advanced_alchemy.repository) QueueEventLogService (class in litestar_queues.backends.advanced_alchemy.service) QueueEventProducer (class in litestar_queues.events.producer) QueueEventPublisher (class in litestar_queues.events.publisher) QueueEventsConfig (class in litestar_queues.events.config) QueueEventSink (class in litestar_queues.events.sinks) QueueEventSizeEstimator (in module litestar_queues.events.chunking) QueueEventStageSummary (class in litestar_queues.events.history) QueueMaintenanceConfig (class in litestar_queues.maintenance) QueueMaintenanceModel (class in litestar_queues.backends.advanced_alchemy.models) QueueMaintenanceModelMixin (class in litestar_queues.backends.advanced_alchemy.mixins) QueueMaintenancePhaseResult (class in litestar_queues.maintenance) QueueMaintenanceService (class in litestar_queues.maintenance) QueueMaintenanceSummary (class in litestar_queues.maintenance) QueueNamespace (class in litestar_queues.config) QueueObservabilityRuntime (class in litestar_queues.observability) QueueObservabilityRuntimeProtocol (class in litestar_queues.observability) QueuePlugin (class in litestar_queues.plugin) queues (litestar_queues.config.WorkerConfig attribute) QueueService (class in litestar_queues.service) QueueStatistics (class in litestar_queues.models) QueueTaskModel (class in litestar_queues.backends.advanced_alchemy.models) QueueTaskModelMixin (class in litestar_queues.backends.advanced_alchemy.mixins) QueueTaskRepository (class in litestar_queues.backends.advanced_alchemy.repository) QueueTaskReservationModel (class in litestar_queues.backends.advanced_alchemy.models) QueueTaskReservationModelMixin (class in litestar_queues.backends.advanced_alchemy.mixins) QueueTaskReservationRepository (class in litestar_queues.backends.advanced_alchemy.repository) QueueTaskReservationService (class in litestar_queues.backends.advanced_alchemy.service) QueueTaskService (class in litestar_queues.backends.advanced_alchemy.service) QueueWarning R RabbitMQExecutionBackend (class in litestar_queues.execution.rabbitmq.backend) RabbitMQExecutionConfig (class in litestar_queues.execution.rabbitmq.config) raise_if_cancelled() (litestar_queues.events.context.TaskExecutionContext method) rebuild_maintenance_indexes() (litestar_queues.backends.redis.backend.RedisQueueBackend method) receive_batch_size (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) reconcile() (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) reconcile_external() (litestar_queues.service.QueueService method) (litestar_queues.worker.Worker method) reconcile_interval (litestar_queues.config.WorkerConfig attribute) record (litestar_queues.task.TaskResult property) record_beat() (litestar_queues.events.context.TaskBeatSink method) record_counter() (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) record_duration() (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) record_exception() (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) record_from_model() (litestar_queues.backends.advanced_alchemy.service.QueueEventLogService static method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService static method) record_gauge_delta() (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) record_histogram() (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) recover_stale_tasks() (litestar_queues.service.QueueService method) RedisBackendConfig (class in litestar_queues.backends.redis.config) RedisQueueBackend (class in litestar_queues.backends.redis.backend) RedisQueueEventLog (class in litestar_queues.backends.redis.event_log) refresh() (litestar_queues.task.TaskResult method) region (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) region_name (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) registration() (litestar_queues.config.QueueNamespace method) release_external_dispatch() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) release_maintenance() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) repair() (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudtasks.backend.CloudTasksExecutionBackend method) (litestar_queues.execution.kafka.backend.KafkaExecutionBackend method) (litestar_queues.execution.pubsub.backend.PubSubExecutionBackend method) (litestar_queues.execution.rabbitmq.backend.RabbitMQExecutionBackend method) (litestar_queues.execution.sqs.backend.SqsExecutionBackend method) replace_execution_ref() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) replay_limit (litestar_queues.events.stream_config.EventStreamConfig attribute) requeue_on_shutdown (litestar_queues.config.WorkerConfig attribute) (litestar_queues.task.Task property) requeue_on_stale (litestar_queues.task.Task property) requeue_stale_running() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) requeued (litestar_queues.models.StaleTaskRecoveryResult attribute) require_current_task_context() (in module litestar_queues.events.context) reserve() (litestar_queues.backends.advanced_alchemy.service.QueueTaskReservationService method) reserve_external_dispatch() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) reserve_identity() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) RESERVED_EVENT_HISTORY_COLUMNS (in module litestar_queues.events.history) reset_correlation_id() (in module litestar_queues.observability) reset_identity() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) reset_task_identity() (litestar_queues.service.QueueService method) resolve() (litestar_queues.events.stream_config.EventStreamConfig method) (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig method) resolve_channels() (litestar_queues.events.publisher.QueueEventPublisher method) resolve_column_map() (in module litestar_queues.backends.sqlspec.schema) resolve_event_history_table_name() (in module litestar_queues.backends.sqlspec.event_log) resolve_job_name() (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig method) resolve_prometheus_registry() (litestar_queues.observability.ObservabilityConfig method) resolve_task() (litestar_queues.service.QueueService method) resource() (litestar_queues.config.QueueNamespace method) response_margin (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) result (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.TaskResult property) result_json (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) retries (litestar_queues.task.Task property) retry_backoff (litestar_queues.task.Task property) retry_count (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.models.QueuedTaskRecord attribute) retry_schedule() (in module litestar_queues.backends.base) retryable() (litestar_queues.execution.base.ExecutionCancelResult class method) RetryBackoff (class in litestar_queues.task) root (litestar_queues.config.QueueNamespace attribute) route_path (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) run() (litestar_queues.maintenance.QueueMaintenanceService method) run_after (litestar_queues.task.Task property) run_consumer() (litestar_queues.execution.base.BaseConsumerExecutionBackend method) (litestar_queues.execution.kafka.backend.KafkaExecutionBackend method) (litestar_queues.execution.pubsub.backend.PubSubExecutionBackend method) (litestar_queues.execution.rabbitmq.backend.RabbitMQExecutionBackend method) (litestar_queues.execution.sqs.backend.SqsExecutionBackend method) run_once() (litestar_queues.worker.Worker method) run_task() (in module litestar_queues.consumer) running (litestar_queues.execution.cloudrun.backend.CloudRunExecutionStatus attribute) (litestar_queues.models.QueueStatistics attribute) S schedule() (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudtasks.backend.CloudTasksExecutionBackend method) ScheduleConfig (class in litestar_queues.task) scheduled (litestar_queues.models.QueueStatistics attribute) scheduled_at (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) scheduler_canary_task (litestar_queues.config.QueueConfig attribute) schedules_on_enqueue (litestar_queues.execution.base.BaseExecutionBackend property) (litestar_queues.execution.cloudtasks.backend.CloudTasksExecutionBackend property) schema_version (litestar_queues.events.models.QueueEvent attribute) scope (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) scope_key (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) scopes (litestar_queues.events.stream_config.EventStreamConfig attribute) select_event_ids_before() (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore method) select_events() (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore method) sequence (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) serialize_detail() (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore method) server_lifespan() (litestar_queues.plugin.QueuePlugin method) service_account_email (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) service_dependency_key (litestar_queues.config.QueueConfig attribute) service_state_key (litestar_queues.config.QueueConfig property) service_url (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) set_attribute() (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) set_default_service() (in module litestar_queues.task) set_event_log() (litestar_queues.events.publisher.QueueEventPublisher method) set_execution_backend() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) set_execution_ref() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) set_observability_runtime() (litestar_queues.events.publisher.QueueEventPublisher method) set_status_error() (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) settings (litestar_queues.backends.sqlspec.config.SQLSpecWorkerWakeupConfig attribute) should_enable_otel() (litestar_queues.observability.ObservabilityConfig method) should_enable_prometheus() (litestar_queues.observability.ObservabilityConfig method) should_enable_sqlcommenter() (litestar_queues.observability.ObservabilityConfig method) signature (litestar_queues.task.Task property) signature_namespace (litestar_queues.config.QueueConfig property) sink (litestar_queues.events.publisher.QueueEventPublisher property) sinks (litestar_queues.events.config.EventDeliveryConfig attribute) (litestar_queues.events.sinks.CompositeQueueEventSink property) skipped (litestar_queues.models.StaleTaskRecoveryResult attribute) source (litestar_queues.events.history.EventHistoryExtraColumn attribute) SpannerQueueEventLogStore (class in litestar_queues.backends.sqlspec.event_log) split_event_batch_by_size() (in module litestar_queues.events.chunking) sqlalchemy_config (litestar_queues.backends.advanced_alchemy.config.SQLAlchemyBackendConfig attribute) SQLAlchemyBackend (class in litestar_queues.backends.advanced_alchemy.backend) SQLAlchemyBackendConfig (class in litestar_queues.backends.advanced_alchemy.config) sqlcommenter_enabled (litestar_queues.observability.QueueObservabilityRuntime property) sqlspec (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) sqlspec_config (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) sqlspec_correlation_context() (in module litestar_queues.typing) SQLSpecBackendConfig (class in litestar_queues.backends.sqlspec.config) SQLSpecQueueBackend (class in litestar_queues.backends.sqlspec.backend) SQLSpecQueueEventLog (class in litestar_queues.backends.sqlspec.event_log) SQLSpecQueueEventLogStore (class in litestar_queues.backends.sqlspec.event_log) SQLSpecWorkerWakeupConfig (class in litestar_queues.backends.sqlspec.config) SqsExecutionBackend (class in litestar_queues.execution.sqs.backend) SqsExecutionConfig (class in litestar_queues.execution.sqs.config) stage (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.history.QueueEventStageSummary attribute) stale_after (litestar_queues.config.WorkerConfig attribute) (litestar_queues.maintenance.QueueMaintenanceConfig attribute) stale_check_interval (litestar_queues.config.WorkerConfig attribute) stale_limit (litestar_queues.maintenance.QueueMaintenanceConfig attribute) STALE_REQUEUE_PRIORITY (in module litestar_queues.config) stale_requeue_priority (litestar_queues.config.QueueConfig attribute) StaleRequeuePriority (in module litestar_queues.config) StaleTaskRecoveryResult (class in litestar_queues.models) start() (litestar_queues.events.buffer.LiveEventBuffer method) (litestar_queues.worker.Worker method) start_buffer() (litestar_queues.events.publisher.QueueEventPublisher method) start_span() (litestar_queues.observability.QueueObservabilityRuntime method) (litestar_queues.observability.QueueObservabilityRuntimeProtocol method) started_at (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.models.QueuedTaskRecord attribute) startup_timeout (litestar_queues.config.WorkerConfig attribute) status (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.execution.base.ExecutionCancelResult attribute) (litestar_queues.maintenance.QueueMaintenancePhaseResult attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.TaskResult property) stop() (litestar_queues.events.buffer.LiveEventBuffer method) (litestar_queues.worker.Worker method) stop_buffer() (litestar_queues.events.publisher.QueueEventPublisher method) stream (litestar_queues.events.config.QueueEventsConfig attribute) StreamMetrics (class in litestar_queues.events.streaming) strict (litestar_queues.events.config.EventDeliveryConfig attribute) (litestar_queues.events.history.EventHistoryConfig attribute) (litestar_queues.events.publisher.QueueEventPublisher attribute) subscription_id (litestar_queues.execution.pubsub.config.PubSubExecutionConfig attribute) subscription_path (litestar_queues.execution.pubsub.config.PubSubExecutionConfig property) succeeded (litestar_queues.execution.cloudrun.backend.CloudRunExecutionStatus attribute) SUCCESS (litestar_queues.consumer.TaskExitCode attribute) summarize_stages() (litestar_queues.backends.advanced_alchemy.event_log.AdvancedAlchemyQueueEventLog method) (litestar_queues.backends.advanced_alchemy.service.QueueEventLogService method) (litestar_queues.backends.memory.event_log.InMemoryQueueEventLog method) (litestar_queues.backends.redis.event_log.RedisQueueEventLog method) (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLog method) (litestar_queues.backends.sqlspec.event_log.SQLSpecQueueEventLogStore method) (litestar_queues.events.history.QueueEventLog method) supports_completion_events (litestar_queues.models.QueueBackendCapabilities attribute) supports_maintenance (litestar_queues.models.QueueBackendCapabilities attribute) supports_worker_wakeups (litestar_queues.models.QueueBackendCapabilities attribute) sync_thread_name_prefix (litestar_queues.config.QueueConfig attribute) sync_thread_pool_size (litestar_queues.config.QueueConfig attribute) sync_to_thread (litestar_queues.task.Task property) T target_url (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig property) Task (class in litestar_queues.task) task() (in module litestar_queues.task) (litestar_queues.events.channels.QueueChannels class method) (litestar_queues.events.producer.QueueEventProducer method) task_dependency_provider (litestar_queues.config.QueueConfig attribute) task_dependency_resolver (litestar_queues.config.QueueConfig attribute) task_id (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskReservationModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskReservationModel attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.models.HeartbeatTouch attribute) (litestar_queues.models.TaskReservation attribute) task_key (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) task_modules (litestar_queues.config.QueueConfig attribute) task_name (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskReservationModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskReservationModel attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.models.TaskRequest attribute) (litestar_queues.models.TaskReservation attribute) (litestar_queues.task.ScheduleConfig attribute) (litestar_queues.task.TaskResult property) task_reservation_model_class (litestar_queues.backends.advanced_alchemy.config.SQLAlchemyBackendConfig attribute) task_reservation_table_name (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) task_reservation_table_name_for() (in module litestar_queues.backends.sqlspec.schema) TaskBeatSink (class in litestar_queues.events.context) TaskDependencyProvider (class in litestar_queues.config) TaskDependencyResolver (in module litestar_queues.config) TaskErrorSanitizer (in module litestar_queues.config) TaskExecutionContext (class in litestar_queues.events.context) TaskExitCode (class in litestar_queues.consumer) TaskIdentityError TaskIdentityTooLargeError TaskRequest (class in litestar_queues.models) TaskReservation (class in litestar_queues.models) TaskResult (class in litestar_queues.task) TaskStatus (in module litestar_queues.models) TaskUniqueBy (in module litestar_queues.task) TaskUniqueUntil (in module litestar_queues.task) terminal_limit (litestar_queues.maintenance.QueueMaintenanceConfig attribute) terminal_retention (litestar_queues.maintenance.QueueMaintenanceConfig attribute) TERMINAL_STATUSES (in module litestar_queues.models) time_budget (litestar_queues.maintenance.QueueMaintenanceConfig attribute) time_until_next_due() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) timeout (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) (litestar_queues.task.Task property) timezone (litestar_queues.task.ScheduleConfig attribute) to_dict() (litestar_queues.events.models.QueueEvent method) (litestar_queues.events.models.QueueEventActor method) (litestar_queues.events.models.QueueEventEntityRef method) to_json() (litestar_queues.events.models.QueueEvent method) to_payload() (litestar_queues.maintenance.QueueMaintenancePhaseResult method) (litestar_queues.maintenance.QueueMaintenanceSummary method) (litestar_queues.models.StaleTaskRecoveryResult method) token (litestar_queues.backends.advanced_alchemy.mixins.QueueMaintenanceModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueMaintenanceModel attribute) topic (litestar_queues.execution.kafka.config.KafkaExecutionConfig attribute) topic_id (litestar_queues.execution.pubsub.config.PubSubExecutionConfig attribute) topic_path (litestar_queues.execution.pubsub.config.PubSubExecutionConfig property) total (litestar_queues.models.QueueStatistics property) total_duration_ms (litestar_queues.events.history.QueueEventStageSummary attribute) touch_heartbeats() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) touched_task_ids (litestar_queues.models.HeartbeatTouchResult attribute) tracer_name (litestar_queues.observability.ObservabilityConfig attribute) tracer_provider (litestar_queues.observability.ObservabilityConfig attribute) transport (litestar_queues.backends.sqlspec.config.SQLSpecWorkerWakeupConfig attribute) transports (litestar_queues.events.stream_config.EventStreamConfig attribute) trust_platform_auth (litestar_queues.execution.cloudtasks.config.CloudTasksExecutionConfig attribute) type (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.events.models.QueueEventActor attribute) (litestar_queues.events.models.QueueEventEntityRef attribute) U unauthenticated_access (litestar_queues.events.stream_config.EventStreamConfig attribute) unique_by (litestar_queues.task.Task property) unique_until (litestar_queues.task.Task property) UNKNOWN_TASK (litestar_queues.consumer.TaskExitCode attribute) unsupported() (litestar_queues.execution.base.ExecutionCancelResult class method) updated_at (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueMaintenanceModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskReservationModel attribute) url (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) using() (litestar_queues.task.Task method) V validate_column_map() (in module litestar_queues.backends.sqlspec.schema) validate_event_extra_filter() (in module litestar_queues.events.history) validate_event_history_extra_columns() (in module litestar_queues.events.history) validate_native_json_columns() (in module litestar_queues.backends.sqlspec.schema) validate_table_name() (in module litestar_queues.backends.sqlspec.schema) ValkeyBackendConfig (class in litestar_queues.backends.valkey.config) ValkeyQueueBackend (class in litestar_queues.backends.valkey.backend) visibility_extension_interval (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) visibility_timeout (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) W wait() (litestar_queues.task.TaskResult method) wait_cancelled() (litestar_queues.events.context.TaskExecutionContext method) wait_for_completion() (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) wait_for_wakeups() (litestar_queues.backends.advanced_alchemy.backend.SQLAlchemyBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) wait_for_worker_control() (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) wait_started() (litestar_queues.worker.Worker method) wait_time_seconds (litestar_queues.execution.sqs.config.SqsExecutionConfig attribute) wakeup_backend (litestar_queues.models.QueueBackendCapabilities attribute) wakeup_channel (litestar_queues.backends.advanced_alchemy.config.SQLAlchemyBackendConfig attribute) (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) wakeup_poll_interval (litestar_queues.backends.advanced_alchemy.config.SQLAlchemyBackendConfig attribute) WAKEUP_TRANSPORTS (in module litestar_queues.backends.sqlspec.config) wakeups_durable (litestar_queues.models.QueueBackendCapabilities attribute) Worker (class in litestar_queues.worker) worker (litestar_queues.config.QueueConfig attribute) worker() (litestar_queues.events.channels.QueueChannels class method) (litestar_queues.events.producer.QueueEventProducer method) worker_id (litestar_queues.backends.advanced_alchemy.mixins.QueueEventHistoryModelMixin attribute) (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.backends.advanced_alchemy.models.QueueEventHistoryModel attribute) (litestar_queues.backends.advanced_alchemy.models.QueueTaskModel attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.history.QueueEventLogRecord attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.worker.Worker property) worker_state_key (litestar_queues.config.QueueConfig property) worker_wakeups (litestar_queues.backends.advanced_alchemy.config.SQLAlchemyBackendConfig attribute) (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) WorkerConfig (class in litestar_queues.config) WorkerPlacement (in module litestar_queues.config) worst_level (litestar_queues.events.history.QueueEventStageSummary attribute)
