Queue Assignment

Assign a DAG to a named queue to control how many instances of DAGs in that queue can run concurrently. Queues themselves are defined in config.yaml — see Queue Configuration.

Assigning a DAG to a Queue

Set the queue field at the top level of a DAG file:

queue: "batch"
schedule: "*/10 * * * *"

steps:
  - id: process
    command: echo "Processing batch"

The scheduler places this DAG into the batch queue. The queue's max_concurrency (defined in config.yaml) determines how many DAGs in this queue can run at the same time.

Default Queue via Base Config

Set a default queue for all DAGs using base.yaml:

# ~/.config/dagu/base.yaml
queue: "default"

Every DAG inherits this unless it sets its own queue field. The corresponding queue must be defined in config.yaml.

See Base Configuration for how base config merging works.

Behavior Without a Queue

When a DAG does not set queue (and no base config default exists), it runs in a local queue named after the DAG itself. Local queues have a fixed concurrency of 1 — only one instance of that DAG runs at a time.

Overriding at Enqueue Time

The --queue flag on dagu enqueue overrides the DAG's queue field:

dagu enqueue --queue=high-priority workflow.yaml

See Queue Configuration for the full enqueue and dequeue CLI reference.