daq_queuing_service

A service to queue DAQ experiments and chain BlueAPI calls

The service combines a queue with a worker that consumes items in the queue and sends them to blueapi. A REST API is exposed to interact with the queue, allowing users to add, move, cancel, and get information about, items in the queue, and pause/unpause the queue.

The server is build with FastAPI. For development and testing, it may be useful to have blueapi and the queue service running locally. To get started, install dependencies into a virtual environment and run the app:

uv sync --group dev
source .venv/bin/activate
podman-compose -f tests/system_tests/compose.yaml up             # Local rabbitmq
blueapi --config tests/test_data/test_blueapi_config.yaml serve  # Local blueapi
daq-queuing-service -p 8001 --dev                                # Local queue service

To instead run the i15-1 setup in a development environment first clone crystallography-bluesky. Then run:

uv sync --group dev
source .venv/bin/activate
uv pip install -e `PATH_TO_CRYSTALLOGRAPHY_BLUESKY`
podman-compose -f tests/system_tests/compose.yaml up                                            # Local rabbitmq
blueapi --config tests/test_data/i15_1/test_blueapi_config.yaml serve                           # Local blueapi pointing at i15-1 plans
daq-queuing-service --config tests/test_data/i15_1/test_daq_queue_config.yaml -p 8001 --dev     # Local queue service pointing at i15-1 converters

See https://diamondlightsource.github.io/daq-queuing-service for more detailed documentation.