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.AdvancedAlchemyQueueBackend method) (litestar_queues.backends.advanced_alchemy.config.AdvancedAlchemyBackendConfig method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.memory.backend.InMemoryQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.redis.config.RedisBackendConfig method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig method) (litestar_queues.backends.valkey.backend.ValkeyQueueBackend method) (litestar_queues.backends.valkey.config.ValkeyBackendConfig method) (litestar_queues.config.AsyncServiceProvider method) (litestar_queues.config.ExecutionBackendConfigProtocol method) (litestar_queues.config.QueueBackendConfigProtocol method) (litestar_queues.config.QueueConfig method) (litestar_queues.config.QueueEventConfig method) (litestar_queues.events.context.TaskExecutionContext method) (litestar_queues.events.litestar.ChannelsQueueEventSink method) (litestar_queues.events.publisher.QueueEventConfig method) (litestar_queues.events.publisher.QueueEventPublisher method) (litestar_queues.events.sinks.InMemoryQueueEventSink method) (litestar_queues.events.sinks.QueueEventSink method) (litestar_queues.exceptions.MissingDependencyError method) (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionStatus method) (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig method) (litestar_queues.models.EnqueueSpec method) (litestar_queues.models.QueueBackendCapabilities method) (litestar_queues.models.QueuedTaskRecord method) (litestar_queues.models.QueueStatistics method) (litestar_queues.models.StaleTaskRecoveryResult method) (litestar_queues.plugin.QueuePlugin method) (litestar_queues.service.QueueService method) (litestar_queues.task.ScheduleConfig method) (litestar_queues.task.Task method) (litestar_queues.task.TaskResult method) (litestar_queues.worker.Worker method) A actor (litestar_queues.events.models.QueueEvent attribute) AdvancedAlchemyBackendConfig (class in litestar_queues.backends.advanced_alchemy.config) AdvancedAlchemyQueueBackend (class in litestar_queues.backends.advanced_alchemy.backend) args (litestar_queues.models.EnqueueSpec attribute) (litestar_queues.models.QueuedTaskRecord attribute) args_json (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) as_metadata() (litestar_queues.task.ScheduleConfig method) AsyncServiceProvider (class in litestar_queues.config) attempt (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.models.QueueEvent attribute) B backend_name (litestar_queues.backends.advanced_alchemy.config.AdvancedAlchemyBackendConfig 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) BaseExecutionBackend (class in litestar_queues.execution.base) BaseQueueBackend (class in litestar_queues.backends.base) build_environment() (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) build_run_job_request() (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) C cancel() (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) cancel_task() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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) cancelled (litestar_queues.execution.cloudrun.backend.CloudRunExecutionStatus attribute) CANCELLED (litestar_queues.execution.cloudrun.entrypoint.CloudRunExitCode attribute) cancelled (litestar_queues.models.QueueStatistics attribute) capabilities (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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) channels_backend (litestar_queues.config.QueueEventConfig attribute) (litestar_queues.events.litestar.ChannelsQueueEventSink property) (litestar_queues.events.publisher.QueueEventConfig attribute) ChannelsQueueEventSink (class in litestar_queues.events.litestar) check_execution_status() (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) CLAIM_LOST (litestar_queues.execution.cloudrun.entrypoint.CloudRunExitCode attribute) claim_next() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend method) (litestar_queues.backends.advanced_alchemy.service.QueueTaskService method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.service.QueueService method) claim_task() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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) cleanup_terminal() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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) clear_task_registry() (in module litestar_queues.task) client (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) close() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.service.QueueService method) CloudRunExecutionBackend (class in litestar_queues.execution.cloudrun.backend) CloudRunExecutionConfig (class in litestar_queues.execution.cloudrun.config) CloudRunExecutionStatus (class in litestar_queues.execution.cloudrun.backend) CloudRunExitCode (class in litestar_queues.execution.cloudrun.entrypoint) column_map (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) complete_task() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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.models.QueuedTaskRecord attribute) config (litestar_queues.backends.base.BaseQueueBackend attribute) (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) (litestar_queues.execution.base.BaseExecutionBackend attribute) (litestar_queues.plugin.QueuePlugin property) (litestar_queues.service.QueueService property) create_queue_store() (in module litestar_queues.backends.sqlspec.stores.factory) create_schema (litestar_queues.backends.advanced_alchemy.config.AdvancedAlchemyBackendConfig attribute) (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) create_schema() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) created_at (litestar_queues.models.QueuedTaskRecord attribute) cron (litestar_queues.task.ScheduleConfig attribute) custom() (litestar_queues.events.channels.QueueChannels class method) D dependencies (litestar_queues.config.QueueConfig property) description (litestar_queues.task.Task property) discover_tasks() (in module litestar_queues.task) dispatch() (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) E enabled (litestar_queues.config.QueueEventConfig attribute) (litestar_queues.events.publisher.QueueEventConfig attribute) enqueue() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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.base.BaseQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) EnqueueSpec (class in litestar_queues.models) entity (litestar_queues.events.models.QueueEvent attribute) env_name() (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig method) env_prefix (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) error (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionStatus attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.TaskResult property) event() (litestar_queues.events.context.TaskExecutionContext method) event_backend (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) event_channel (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) event_config (litestar_queues.config.QueueConfig attribute) event_key (litestar_queues.events.models.QueueEvent attribute) event_poll_interval (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) event_publisher (litestar_queues.events.context.TaskExecutionContext attribute) event_queue_table (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) event_settings (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) events (litestar_queues.events.sinks.InMemoryQueueEventSink property) events_for() (litestar_queues.events.sinks.InMemoryQueueEventSink method) execute() (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) (litestar_queues.execution.immediate.ImmediateExecutionBackend method) (litestar_queues.execution.local.LocalExecutionBackend method) execute_cloudrun_task() (in module litestar_queues.execution.cloudrun.entrypoint) execute_record() (litestar_queues.service.QueueService method) (litestar_queues.task.Task method) execution_backend (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.config.QueueConfig attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.models.EnqueueSpec attribute) (litestar_queues.models.QueuedTaskRecord 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) execution_profile (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.models.EnqueueSpec attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.Task property) execution_ref (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.models.QueuedTaskRecord attribute) ExecutionBackendConfig (in module litestar_queues.config) ExecutionBackendConfigProtocol (class in litestar_queues.config) executions_client (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend attribute) extra_env (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) F fail_task() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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.execution.cloudrun.entrypoint.CloudRunExitCode attribute) fallback_execution_backend (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) for_model() (litestar_queues.backends.advanced_alchemy.repository.QueueTaskRepository 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_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_next_run() (litestar_queues.task.ScheduleConfig 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.AdvancedAlchemyQueueBackend 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() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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.AdvancedAlchemyQueueBackend 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_registry() (in module litestar_queues.task) global_channel() (litestar_queues.events.channels.QueueChannels class method) H handler_needed (litestar_queues.models.StaleTaskRecoveryResult attribute) handler_needed_task_ids (litestar_queues.models.StaleTaskRecoveryResult attribute) heartbeat_at (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.models.QueuedTaskRecord attribute) heartbeat_pool_config (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) heartbeat_session_maker (litestar_queues.backends.advanced_alchemy.config.AdvancedAlchemyBackendConfig attribute) I id (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) ImmediateExecutionBackend (class in litestar_queues.execution.immediate) in_app_worker (litestar_queues.config.QueueConfig attribute) initial_delay (litestar_queues.task.ScheduleConfig attribute) initialize_schedules (litestar_queues.config.QueueConfig attribute) initialize_schedules() (litestar_queues.service.QueueService method) InMemoryQueueBackend (class in litestar_queues.backends.memory.backend) InMemoryQueueEventSink (class in litestar_queues.events.sinks) interval (litestar_queues.task.ScheduleConfig attribute) INVALID_TASK_ID (litestar_queues.execution.cloudrun.entrypoint.CloudRunExitCode attribute) is_due (litestar_queues.models.QueuedTaskRecord property) is_external (litestar_queues.execution.base.BaseExecutionBackend property) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend property) 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_name (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) jobs_client (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend attribute) K key (litestar_queues.models.EnqueueSpec attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.Task property) key_prefix (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) kwargs (litestar_queues.models.EnqueueSpec attribute) (litestar_queues.models.QueuedTaskRecord attribute) kwargs_json (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) L level (litestar_queues.events.models.QueueEvent attribute) lifecycle() (litestar_queues.events.context.TaskExecutionContext method) list_completed_by_task() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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.AdvancedAlchemyQueueBackend 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.AdvancedAlchemyQueueBackend 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.mixins 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.redis.backend module litestar_queues.backends.redis.config module litestar_queues.backends.sqlspec.backend module litestar_queues.backends.sqlspec.config 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.events.channels module litestar_queues.events.context module litestar_queues.events.litestar module litestar_queues.events.models module litestar_queues.events.publisher module litestar_queues.events.sinks 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.cloudrun.entrypoint module litestar_queues.execution.immediate module litestar_queues.execution.local module litestar_queues.models module litestar_queues.plugin module litestar_queues.service module litestar_queues.task module litestar_queues.worker module load_task_modules() (in module litestar_queues.task) LocalExecutionBackend (class in litestar_queues.execution.local) lock_timeout (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) log() (litestar_queues.events.context.TaskExecutionContext method) log_level (litestar_queues.task.Task property) M main() (in module litestar_queues.execution.cloudrun.entrypoint) manage_schema (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) max_instances (litestar_queues.task.ScheduleConfig attribute) max_retries (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.models.EnqueueSpec attribute) (litestar_queues.models.QueuedTaskRecord attribute) message (litestar_queues.events.models.QueueEvent attribute) metadata (litestar_queues.models.EnqueueSpec attribute) (litestar_queues.models.QueuedTaskRecord attribute) metadata() (litestar_queues.task.Task method) metadata_json (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) migration_directory() (in module litestar_queues.backends.sqlspec.schema) migration_paths() (in module litestar_queues.backends.sqlspec.schema) MISSING_RECORD (litestar_queues.execution.cloudrun.entrypoint.CloudRunExitCode attribute) MISSING_TASK_ID (litestar_queues.execution.cloudrun.entrypoint.CloudRunExitCode attribute) MissingDependencyError model_class (litestar_queues.backends.advanced_alchemy.config.AdvancedAlchemyBackendConfig attribute) model_from_record() (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.mixins litestar_queues.backends.advanced_alchemy.repository litestar_queues.backends.advanced_alchemy.service litestar_queues.backends.base litestar_queues.backends.memory.backend litestar_queues.backends.redis.backend litestar_queues.backends.redis.config litestar_queues.backends.sqlspec.backend litestar_queues.backends.sqlspec.config 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.events.channels litestar_queues.events.context litestar_queues.events.litestar litestar_queues.events.models litestar_queues.events.publisher litestar_queues.events.sinks litestar_queues.exceptions litestar_queues.execution.base litestar_queues.execution.cloudrun.backend litestar_queues.execution.cloudrun.config litestar_queues.execution.cloudrun.entrypoint litestar_queues.execution.immediate litestar_queues.execution.local litestar_queues.models litestar_queues.plugin litestar_queues.service litestar_queues.task litestar_queues.worker N name (litestar_queues.events.models.QueueEventActor attribute) (litestar_queues.events.models.QueueEventEntityRef attribute) (litestar_queues.task.Task property) native_json_columns (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) non_retryable() (in module litestar_queues.exceptions) NonRetryableError NoopQueueEventSink (class in litestar_queues.events.sinks) notification_backend (litestar_queues.models.QueueBackendCapabilities attribute) notification_channel (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) notifications (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) notifications_durable (litestar_queues.models.QueueBackendCapabilities attribute) notify_new_task() (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_transport (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) NOTIFY_TRANSPORTS (in module litestar_queues.backends.sqlspec.config) null_heartbeats() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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 occurred_at (litestar_queues.events.models.QueueEvent attribute) on_app_init() (litestar_queues.plugin.QueuePlugin method) on_cli_init() (litestar_queues.plugin.QueuePlugin method) open() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend method) (litestar_queues.backends.base.BaseQueueBackend method) (litestar_queues.backends.redis.backend.RedisQueueBackend method) (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.service.QueueService method) P payload (litestar_queues.events.models.QueueEvent attribute) pending (litestar_queues.models.QueueStatistics attribute) poll_interval (litestar_queues.backends.redis.config.RedisBackendConfig attribute) (litestar_queues.backends.valkey.config.ValkeyBackendConfig attribute) (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) prefix (litestar_queues.events.channels.QueueChannels attribute) priority (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.models.EnqueueSpec attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.Task property) profiles (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) progress() (litestar_queues.events.context.TaskExecutionContext method) progress_current (litestar_queues.events.models.QueueEvent attribute) progress_percent (litestar_queues.events.models.QueueEvent attribute) progress_total (litestar_queues.events.models.QueueEvent attribute) project_id (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) provide_service() (litestar_queues.config.QueueConfig method) provide_service_dependency() (litestar_queues.config.QueueConfig method) publish() (litestar_queues.events.context.TaskExecutionContext method) (litestar_queues.events.litestar.ChannelsQueueEventSink method) (litestar_queues.events.publisher.QueueEventPublisher 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_global_lifecycle (litestar_queues.config.QueueEventConfig attribute) (litestar_queues.events.publisher.QueueEventConfig attribute) (litestar_queues.events.publisher.QueueEventPublisher attribute) publish_queue_channel (litestar_queues.config.QueueEventConfig attribute) (litestar_queues.events.publisher.QueueEventConfig attribute) (litestar_queues.events.publisher.QueueEventPublisher attribute) publish_task_channel (litestar_queues.config.QueueEventConfig attribute) (litestar_queues.events.publisher.QueueEventConfig 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) Q queue (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.models.EnqueueSpec attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.Task property) queue() (litestar_queues.events.channels.QueueChannels class method) queue_backend (litestar_queues.config.QueueConfig attribute) queue_backend() (in module litestar_queues.backends) queue_backend_name() (in module litestar_queues.config) queue_event_channels_backend_state_key (litestar_queues.config.QueueConfig attribute) queue_event_publisher_state_key (litestar_queues.config.QueueConfig attribute) queue_observability (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) queue_service_dependency_key (litestar_queues.config.QueueConfig attribute) queue_service_state_key (litestar_queues.config.QueueConfig attribute) queue_worker_state_key (litestar_queues.config.QueueConfig 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 QueuedTaskRecord (class in litestar_queues.models) QueueError QueueEvent (class in litestar_queues.events.models) QueueEventActor (class in litestar_queues.events.models) QueueEventConfig (class in litestar_queues.config) (class in litestar_queues.events.publisher) QueueEventEntityRef (class in litestar_queues.events.models) QueueEventPublisher (class in litestar_queues.events.publisher) QueueEventSink (class in litestar_queues.events.sinks) QueuePlugin (class in litestar_queues.plugin) QueueService (class in litestar_queues.service) QueueStatistics (class in litestar_queues.models) QueueTaskModelMixin (class in litestar_queues.backends.advanced_alchemy.mixins) QueueTaskRepository (class in litestar_queues.backends.advanced_alchemy.repository) QueueTaskService (class in litestar_queues.backends.advanced_alchemy.service) quiet_success (litestar_queues.task.Task property) R reconcile() (litestar_queues.execution.base.BaseExecutionBackend method) (litestar_queues.execution.cloudrun.backend.CloudRunExecutionBackend method) reconcile_external() (litestar_queues.worker.Worker method) record (litestar_queues.task.TaskResult property) record_from_model() (litestar_queues.backends.advanced_alchemy.service.QueueTaskService static 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) refresh() (litestar_queues.task.TaskResult method) region (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) requeue_on_stale (litestar_queues.task.Task property) requeue_stale_running() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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) resolve_channels() (litestar_queues.events.publisher.QueueEventPublisher method) resolve_job_name() (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig method) resolve_task() (litestar_queues.service.QueueService method) result (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.TaskResult property) result_json (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) retries (litestar_queues.task.Task property) retry_count (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.models.QueuedTaskRecord attribute) run_after (litestar_queues.task.Task property) run_migrations (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) run_migrations() (litestar_queues.backends.sqlspec.backend.SQLSpecQueueBackend method) run_once() (litestar_queues.worker.Worker method) running (litestar_queues.execution.cloudrun.backend.CloudRunExecutionStatus attribute) (litestar_queues.models.QueueStatistics attribute) S ScheduleConfig (class in litestar_queues.task) scheduled (litestar_queues.models.QueueStatistics attribute) scheduled_at (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.models.EnqueueSpec attribute) (litestar_queues.models.QueuedTaskRecord attribute) scheduler_canary_task (litestar_queues.config.QueueConfig attribute) schema_version (litestar_queues.events.models.QueueEvent attribute) scope (litestar_queues.events.models.QueueEvent attribute) scope_key (litestar_queues.events.models.QueueEvent attribute) sequence (litestar_queues.events.models.QueueEvent attribute) set_default_service() (in module litestar_queues.task) set_execution_backend() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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.AdvancedAlchemyQueueBackend 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) signature_namespace (litestar_queues.config.QueueConfig property) sink (litestar_queues.config.QueueEventConfig attribute) (litestar_queues.events.publisher.QueueEventConfig attribute) (litestar_queues.events.publisher.QueueEventPublisher property) skipped (litestar_queues.models.StaleTaskRecoveryResult attribute) sqlalchemy_config (litestar_queues.backends.advanced_alchemy.config.AdvancedAlchemyBackendConfig attribute) sqlspec (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) SQLSpecBackendConfig (class in litestar_queues.backends.sqlspec.config) SQLSpecQueueBackend (class in litestar_queues.backends.sqlspec.backend) StaleTaskRecoveryResult (class in litestar_queues.models) start() (litestar_queues.worker.Worker method) started_at (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.models.QueuedTaskRecord attribute) status (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.TaskResult property) stop() (litestar_queues.worker.Worker method) stream_queue_events() (in module litestar_queues.events.litestar) strict (litestar_queues.config.QueueEventConfig attribute) (litestar_queues.events.publisher.QueueEventConfig attribute) (litestar_queues.events.publisher.QueueEventPublisher attribute) succeeded (litestar_queues.execution.cloudrun.backend.CloudRunExecutionStatus attribute) SUCCESS (litestar_queues.execution.cloudrun.entrypoint.CloudRunExitCode attribute) supports_atomic_claim (litestar_queues.models.QueueBackendCapabilities attribute) supports_atomic_delayed_promotion (litestar_queues.models.QueueBackendCapabilities attribute) supports_external_refs (litestar_queues.models.QueueBackendCapabilities attribute) supports_heartbeats (litestar_queues.models.QueueBackendCapabilities attribute) supports_notifications (litestar_queues.models.QueueBackendCapabilities attribute) supports_terminal_cleanup (litestar_queues.models.QueueBackendCapabilities attribute) sync_executor_max_workers (litestar_queues.config.QueueConfig attribute) sync_executor_thread_name_prefix (litestar_queues.config.QueueConfig attribute) T table_name (litestar_queues.backends.sqlspec.config.SQLSpecBackendConfig attribute) Task (class in litestar_queues.task) task() (in module litestar_queues.task) (litestar_queues.events.channels.QueueChannels class method) task_dependency_resolver (litestar_queues.config.QueueConfig attribute) task_id (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.models.QueueEvent attribute) task_key (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) task_modules (litestar_queues.config.QueueConfig attribute) task_name (litestar_queues.backends.advanced_alchemy.mixins.QueueTaskModelMixin attribute) (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.models.EnqueueSpec attribute) (litestar_queues.models.QueuedTaskRecord attribute) (litestar_queues.task.ScheduleConfig attribute) (litestar_queues.task.TaskResult property) TaskDependencyResolver (in module litestar_queues.config) TaskExecutionContext (class in litestar_queues.events.context) TaskResult (class in litestar_queues.task) TaskStatus (in module litestar_queues.models) TERMINAL_STATUSES (in module litestar_queues.models) timeout (litestar_queues.execution.cloudrun.config.CloudRunExecutionConfig attribute) (litestar_queues.task.ScheduleConfig 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.models.StaleTaskRecoveryResult method) total (litestar_queues.models.QueueStatistics property) touch_heartbeat() (litestar_queues.backends.advanced_alchemy.backend.AdvancedAlchemyQueueBackend 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) type (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.events.models.QueueEventActor attribute) (litestar_queues.events.models.QueueEventEntityRef attribute) U UNKNOWN_TASK (litestar_queues.execution.cloudrun.entrypoint.CloudRunExitCode 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_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) W wait() (litestar_queues.task.TaskResult method) wait_for_notifications() (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) Worker (class in litestar_queues.worker) worker() (litestar_queues.events.channels.QueueChannels class method) worker_batch_size (litestar_queues.config.QueueConfig attribute) worker_final_cancel_timeout (litestar_queues.config.QueueConfig attribute) worker_graceful_shutdown_timeout (litestar_queues.config.QueueConfig attribute) worker_heartbeat_interval (litestar_queues.config.QueueConfig attribute) worker_id (litestar_queues.events.context.TaskExecutionContext attribute) (litestar_queues.events.models.QueueEvent attribute) (litestar_queues.worker.Worker property) worker_max_concurrency (litestar_queues.config.QueueConfig attribute) worker_poll_interval (litestar_queues.config.QueueConfig attribute) worker_queues (litestar_queues.config.QueueConfig attribute) worker_reconcile_interval (litestar_queues.config.QueueConfig attribute) worker_stale_after (litestar_queues.config.QueueConfig attribute) worker_stale_check_interval (litestar_queues.config.QueueConfig attribute)
