litestar-queues litestar-queues litestar-queues
    • Start here Install the package and enqueue your first task.
    • Concepts Understand task records, workers, backends, and events.
    • How-to guides Complete focused task, worker, backend, and event goals.
    • Examples Run WebSocket and SSE applications with backend variants.
    • Reference Browse the public queue, backend, worker, and event APIs.
    • Contributing Set up the repo and follow project conventions.
    • Testing Run unit, integration, backend, and docs checks.
    • Documentation Write and audit focused, source-backed documentation.
    • Discord Ask questions in the Litestar community.
    • GitHub Discussions Discuss usage, design, and support topics on GitHub.
/
  • Discussion

Documentation

  • Start here
    • Installation
    • Quickstart
    • Introduction
  • Concepts
  • How-to guides
    • Concepts
    • Define and enqueue
    • Task options
    • Results
    • Background responses
    • Failures and cancellation
    • Schedules
    • Run workers
    • Worker wakeups
    • Worker recovery
    • Configuration
    • Command-Line Interface
    • Queue maintenance
    • Testing tasks
    • Choose backends
    • SQLSpec backend
    • Advanced Alchemy backend
    • Redis and Valkey backends
    • Task events
    • SSE and WebSockets
    • Event history
    • Test task events
    • Observability
    • Dependency Resolver
    • Cloud Run Deployment
    • Persistent storage setup
  • Examples gallery
  • API Reference
    • Core API
    • Queue Backends
    • Execution Backends
    • Events
    • Reference Map

Developers

  • Contributing
    • Testing
    • Writing documentation
  • Changelog
  1. litestar-queues /
  2. Examples gallery
View Source Open in ChatGPT Open in Claude

Examples gallery#

Start with a memory example. It runs the web app, queue worker, and live Channels delivery in one process. Choose a backend variant only after the transport is working.

Memory WebSocket

HTMX WebSocket updates with memory queue persistence and memory Channels.

https://github.com/cofin/litestar-queues/tree/main/examples/htmx_realtime_websocket
Memory SSE

HTMX Server-Sent Events with memory queue persistence and memory Channels.

https://github.com/cofin/litestar-queues/tree/main/examples/htmx_realtime_sse
SQL backends

Run the SQLSpec or Advanced Alchemy copies with SQLite, then adapt schema ownership.

Choose backends
Redis and Valkey

Run local copies or opt into shared Channels and a standalone worker.

Redis and Valkey backends

Every variant has its own README, application module, templates, frontend source, and asset commands. The memory apps are the main examples. The backend copies show only how persistence changes.

Note

Selecting Redis or Valkey for queue storage does not configure browser event delivery. By default, the examples use Channels in one process. To run a separate worker, set both the shared-Channels and standalone-worker environment variables described in the example README.

See SSE and WebSockets for the source imports and delivery contract, or browse the complete examples directory.

Previous
Persistent storage setup
Next
API Reference

2026, Litestar-Org

Made with Sphinx and Shibuya theme.