pulq

Contents

  • Getting started
  • Architecture
  • Scheduling (WDRR)
  • Extending PULQ
  • API reference
pulq
  • PULQ
  • View page source

PULQ

Fair pull-based task scheduling for asyncio, with Weighted Deficit Round Robin (WDRR) priority service and per-worker management commands.

Contents

  • Getting started
    • Install
    • Editable install (development)
    • Minimal example
  • Architecture
    • Components
    • Data models (pulq.models)
    • Discriminated unions
  • Scheduling (WDRR)
  • Extending PULQ
    • Custom TaskRepository
    • Custom Transport
    • Management commands
  • API reference
    • CommandDispatcher
    • CommandType
    • DeficitScheduler
    • DeficitSchedulerConfig
    • HeartbeatCallback
    • InMemoryTaskRepository
    • LocalTransport
    • ManagementCommand
    • NoPendingTask
    • NoWork
    • NoWorkReason
    • PullQueue
    • Queue
    • Task
    • TaskHandler
    • TaskRepository
    • TaskStatus
    • Transport
    • Worker
    • parse_claim_result()
    • parse_work_response()
    • PullQueue
    • DeficitScheduler
    • CommandDispatcher
    • Worker
    • CommandType
    • NoWorkReason
    • TaskStatus
    • Task
    • ManagementCommand
    • NoPendingTask
    • NoWork
    • DeficitSchedulerConfig
    • parse_claim_result()
    • parse_work_response()
    • InMemoryTaskRepository
    • LocalTransport
    • HeartbeatCallback
    • TaskHandler
    • TaskRepository
    • Transport

Indices

  • Index

  • Module Index

Next

© Copyright 2026, Vadim Schultz.

Built with Sphinx using a theme provided by Read the Docs.