-
Notifications
You must be signed in to change notification settings - Fork 16.3k
Description
View
Search - Task Instances
Filters to Add
-
Filter by DAG ID
↪ Useful to narrow scope in multi-DAG environments -
Filter by Run ID
↪ Investigate behavior within a single DAG run -
Filter by Map Index
↪ Especially useful for expanded tasks -
Filter by Start Date Range
↪ Especially useful for looking for tasks running at the same time -
Filter by EndDate Range
↪ Especially useful for looking for tasks running at the same time -
Filter by Try Number
↪ Spot retries or stuck tasks -
Filter by Pool
↪ Infra monitoring or debugging -
Filter by Operator Type
↪ Example:PythonOperator,BashOperator -
Filter by Duration Range
↪ Identify long-running or underperforming tasks -
Filter by DAG Version and/or Bundle Version
↪ Correlate failures with code changes -
Filter by Logical Date and/or Run After Date from DAG
↪ Range or specific execution window
API Support
/taskInstancessupports query params for:dag_id,dag_run_id,task_id,map_index,state,pool,queue,execution_date
- Missing support for:
- Operator type
- DAG/Bundle version
- Try number
- Duration range
Would require extending API filtering logic and UI bindings.
UI Impact
- Filters added to top of the Task Instances view (Search – Task Instances)
- Should use consistent UX patterns for multi-selects, text input, and range pickers
- Filter state should persist on refresh if possible