Changelog

All notable changes to this project will be documented in this file.

The format is loosely based on Keep a Changelog.

Unreleased

QueueVar for user-defined serializable context variables that propagate across queue boundaries.
QueueContext mapping to access captured context on invocations.
priority is now a QueueVar instance (same context manager syntax as before).

Priority support for invocations (0-9, default 4). Use the priority() context manager to set the priority for invocations created within its scope. Priority propagates to descendent invocations.
sync --recreate flag to delete and recreate all queues.
Invocation.Submitted events now include priority.

The queueio CLI entry point was broken by a build configuration that excluded the package source.

The journal now uses a threadsafe pika connection, rather than guarding a blocking connection.
The integration tests and examples have better queue names.

Thank you to Nick Anderegg for allowing me to use the queueio name for this project.

routine decorator to declare sync or async functions as background routines.
activate context manager to activate the queueio system.
pause to coordinate a pause of a routine to queueio.
gather to run multiple routines concurrently and gather the results.
Routine.submit() method to submit a routine invocation to the queue.
Configuration in the tool.queueio section of pyproject.toml.
pika configures the pika library to connect to the AMQP broker.
register configures the modules that declare routines.
QUEUEIO_PIKA environment variable to override the pika configuration in pyproject.toml.
queueio sync command to synchronize queues to the broker.
queueio run command to run the queueio worker.
The queuespec syntax to queue run to consume multiple queues with shared capacity.
queueio monitor command to monitor activity in the queueio system.