Skip to content

[Filters] Add task-level filters to DAG View - Graph tab #53044

@cmarteepants

Description

@cmarteepants

View

DAG View - Graph Tab

Image

Filters to Add

  • Filter by Task Group
    ↪ Useful for narrowing view to a specific section of a large DAG

  • Filter by Operator
    ↪ Helps identify all tasks of a certain type (e.g., BashOperator vs. PythonOperator) within the DAG

When looking at graph for specific Dag Run:

  • Filter by Task Status (Success, Failed, Skipped, etc.) when looking at graph for specific dag run
    ↪ Helps users focus on problematic tasks or ignore successful ones in complex DAGs

  • Filter by Mapped Index (for mapped tasks) when looking at graph for a specific dag run
    ↪ Supports debugging of specific mapped task instances when hundreds exist

  • Filter by Duration Threshold
    ↪ Highlight long-running tasks for performance triage or resource bottlenecks

API Support

❌ No

  • The Graph View uses the DAG structure and DAG Run state but does not currently expose API query parameters for task-level filtering.
  • Data exists in task instances API but is not integrated here.

UI Impact

  • Filters could appear above the DAG Graph or in a collapsible sidebar.
  • Task nodes would update based on filter selection; unmatching nodes could be dimmed or hidden.

Notes

  • Particularly valuable for large DAGs with many tasks and/or dynamic mapping
  • Could integrate with color coding to enhance visibility of filter results

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions