Skip to content

Add queue override parameter for enqueue operations #1111

@yottahmd

Description

@yottahmd

Reported by: @ghansham

Problem

Queue names are hardcoded in DAG YAML files. When reprocessing data with different priorities (e.g., realtime vs historical), the same high-priority queue is always used.

Solution

Add optional parameter to override DAG-level queue definition.

Changes

  • Add --queue flag to enqueue CLI command
  • Add queue parameter to enqueue API endpoints
  • Update queue resolution logic to use override if provided

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementNew feature to be implemented

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions