Concepts API Examples Changelog

Docs for

Tasks & execution

Tasks Task discovery Queues & Priority Workers Execution Models Enqueue options Scheduling Cancellation Predicates Task batching Batch Enqueue Unique Tasks Task Dependencies Result Streaming Native Async Tasks Prefork Worker Pool Topic Pub/Sub

Extend & integrate

Python/Guides/

Tasks & execution

The building blocks of every flexiq application.

← PreviousGuides Next →Tasks

TasksDefine tasks with @queue.task(), configure retries, timeouts, and options Task DiscoveryDeclare tasks with @flexiq.task() and claim them with autodiscover()WorkersStart workers, control concurrency, graceful shutdown Execution ModelsHow tasks move from enqueue to completion Queues & PriorityNamed queues, priority levels, and routing Enqueue OptionsPer-job overrides — priority, delay, timeout, dedup keys, expiry, dependencies CancellationCancel a pending job, ask a running one to stop, report progress SchedulingPeriodic tasks with cron expressions PredicatesGate execution with a serializable predicate DSL — time windows, feature flags Task BatchingCollect many small calls into a single job Batch EnqueueSubmit many jobs in one round trip Unique TasksCollapse duplicate submissions onto one job Task DependenciesHold a job until the jobs it depends on finish Result StreamingEmit partial results while a task is still running Native Async TasksRun coroutine tasks on an asyncio worker pool Prefork Worker PoolFork worker processes to sidestep the GIL Pub/SubFan a published message out to independent subscribers, each its own job