This is an automated email from the ASF dual-hosted git repository.
pierrejeambrun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 45678e8ad4c feat(task_instances): Add operator_name_pattern
pool_pattern queue_pattern as search filter (#57571)
45678e8ad4c is described below
commit 45678e8ad4c57239f324c434ffaab24f0a7515cb
Author: Sean Yu <[email protected]>
AuthorDate: Tue Nov 4 22:15:24 2025 +0800
feat(task_instances): Add operator_name_pattern pool_pattern queue_pattern
as search filter (#57571)
* add pool_pattern queue_pattern operator_name_pattern as ti search filter
* trim white space
* add generated description
* add codegen's generated changes
* change pool's and queue's search filter to *_name_pattern
---
.../src/airflow/api_fastapi/common/parameters.py | 18 ++++++
.../core_api/openapi/v2-rest-api-generated.yaml | 72 ++++++++++++++++++++++
.../core_api/routes/public/task_instances.py | 15 +++++
.../src/airflow/ui/openapi-gen/queries/common.ts | 14 +++--
.../ui/openapi-gen/queries/ensureQueryData.ts | 20 ++++--
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 20 ++++--
.../src/airflow/ui/openapi-gen/queries/queries.ts | 20 ++++--
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 20 ++++--
.../ui/openapi-gen/requests/services.gen.ts | 12 ++++
.../airflow/ui/openapi-gen/requests/types.gen.ts | 24 ++++++++
.../core_api/routes/public/test_task_instances.py | 40 ++++++++++++
11 files changed, 255 insertions(+), 20 deletions(-)
diff --git a/airflow-core/src/airflow/api_fastapi/common/parameters.py
b/airflow-core/src/airflow/api_fastapi/common/parameters.py
index f3c05b218fb..2f60b13b27e 100644
--- a/airflow-core/src/airflow/api_fastapi/common/parameters.py
+++ b/airflow-core/src/airflow/api_fastapi/common/parameters.py
@@ -872,6 +872,15 @@ QueryTIQueueFilter = Annotated[
filter_param_factory(TaskInstance.queue, list[str],
FilterOptionEnum.ANY_EQUAL, default_factory=list)
),
]
+QueryTIPoolNamePatternSearch = Annotated[
+ _SearchParam,
+ Depends(search_param_factory(TaskInstance.pool, "pool_name_pattern")),
+]
+
+QueryTIQueueNamePatternSearch = Annotated[
+ _SearchParam,
+ Depends(search_param_factory(TaskInstance.queue, "queue_name_pattern")),
+]
QueryTIExecutorFilter = Annotated[
FilterParam[list[str]],
Depends(
@@ -923,6 +932,15 @@ QueryTIOperatorFilter = Annotated[
)
),
]
+QueryTIOperatorNamePatternSearch = Annotated[
+ _SearchParam,
+ Depends(
+ search_param_factory(
+ TaskInstance.custom_operator_name,
+ "operator_name_pattern",
+ )
+ ),
+]
QueryTIMapIndexFilter = Annotated[
FilterParam[list[int]],
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml
b/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml
index 4f13f8e75d1..23fb5c7d8c2 100644
---
a/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml
+++
b/airflow-core/src/airflow/api_fastapi/core_api/openapi/v2-rest-api-generated.yaml
@@ -5759,6 +5759,18 @@ paths:
items:
type: string
title: Pool
+ - name: pool_name_pattern
+ in: query
+ required: false
+ schema:
+ anyOf:
+ - type: string
+ - type: 'null'
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards
(e.g. `%customer_%`).\
+ \ Regular expressions are **not** supported."
+ title: Pool Name Pattern
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g.
`%customer_%`).\
+ \ Regular expressions are **not** supported."
- name: queue
in: query
required: false
@@ -5767,6 +5779,18 @@ paths:
items:
type: string
title: Queue
+ - name: queue_name_pattern
+ in: query
+ required: false
+ schema:
+ anyOf:
+ - type: string
+ - type: 'null'
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards
(e.g. `%customer_%`).\
+ \ Regular expressions are **not** supported."
+ title: Queue Name Pattern
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g.
`%customer_%`).\
+ \ Regular expressions are **not** supported."
- name: executor
in: query
required: false
@@ -5799,6 +5823,18 @@ paths:
items:
type: string
title: Operator
+ - name: operator_name_pattern
+ in: query
+ required: false
+ schema:
+ anyOf:
+ - type: string
+ - type: 'null'
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards
(e.g. `%customer_%`).\
+ \ Regular expressions are **not** supported."
+ title: Operator Name Pattern
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g.
`%customer_%`).\
+ \ Regular expressions are **not** supported."
- name: map_index
in: query
required: false
@@ -6589,6 +6625,18 @@ paths:
items:
type: string
title: Pool
+ - name: pool_name_pattern
+ in: query
+ required: false
+ schema:
+ anyOf:
+ - type: string
+ - type: 'null'
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards
(e.g. `%customer_%`).\
+ \ Regular expressions are **not** supported."
+ title: Pool Name Pattern
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g.
`%customer_%`).\
+ \ Regular expressions are **not** supported."
- name: queue
in: query
required: false
@@ -6597,6 +6645,18 @@ paths:
items:
type: string
title: Queue
+ - name: queue_name_pattern
+ in: query
+ required: false
+ schema:
+ anyOf:
+ - type: string
+ - type: 'null'
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards
(e.g. `%customer_%`).\
+ \ Regular expressions are **not** supported."
+ title: Queue Name Pattern
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g.
`%customer_%`).\
+ \ Regular expressions are **not** supported."
- name: executor
in: query
required: false
@@ -6629,6 +6689,18 @@ paths:
items:
type: string
title: Operator
+ - name: operator_name_pattern
+ in: query
+ required: false
+ schema:
+ anyOf:
+ - type: string
+ - type: 'null'
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards
(e.g. `%customer_%`).\
+ \ Regular expressions are **not** supported."
+ title: Operator Name Pattern
+ description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g.
`%customer_%`).\
+ \ Regular expressions are **not** supported."
- name: map_index
in: query
required: false
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/task_instances.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/task_instances.py
index 25263a0e237..7c9fb009a04 100644
---
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/task_instances.py
+++
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/task_instances.py
@@ -45,8 +45,11 @@ from airflow.api_fastapi.common.parameters import (
QueryTIExecutorFilter,
QueryTIMapIndexFilter,
QueryTIOperatorFilter,
+ QueryTIOperatorNamePatternSearch,
QueryTIPoolFilter,
+ QueryTIPoolNamePatternSearch,
QueryTIQueueFilter,
+ QueryTIQueueNamePatternSearch,
QueryTIStateFilter,
QueryTITaskDisplayNamePatternSearch,
QueryTITryNumberFilter,
@@ -150,11 +153,14 @@ def get_mapped_task_instances(
duration_range: Annotated[RangeFilter,
Depends(float_range_filter_factory("duration", TI))],
state: QueryTIStateFilter,
pool: QueryTIPoolFilter,
+ pool_name_pattern: QueryTIPoolNamePatternSearch,
queue: QueryTIQueueFilter,
+ queue_name_pattern: QueryTIQueueNamePatternSearch,
executor: QueryTIExecutorFilter,
version_number: QueryTIDagVersionFilter,
try_number: QueryTITryNumberFilter,
operator: QueryTIOperatorFilter,
+ operator_name_pattern: QueryTIOperatorNamePatternSearch,
map_index: QueryTIMapIndexFilter,
limit: QueryLimit,
offset: QueryOffset,
@@ -221,11 +227,14 @@ def get_mapped_task_instances(
duration_range,
state,
pool,
+ pool_name_pattern,
queue,
+ queue_name_pattern,
executor,
version_number,
try_number,
operator,
+ operator_name_pattern,
map_index,
],
order_by=order_by,
@@ -418,11 +427,14 @@ def get_task_instances(
dag_id_pattern: Annotated[_SearchParam,
Depends(search_param_factory(TI.dag_id, "dag_id_pattern"))],
state: QueryTIStateFilter,
pool: QueryTIPoolFilter,
+ pool_name_pattern: QueryTIPoolNamePatternSearch,
queue: QueryTIQueueFilter,
+ queue_name_pattern: QueryTIQueueNamePatternSearch,
executor: QueryTIExecutorFilter,
version_number: QueryTIDagVersionFilter,
try_number: QueryTITryNumberFilter,
operator: QueryTIOperatorFilter,
+ operator_name_pattern: QueryTIOperatorNamePatternSearch,
map_index: QueryTIMapIndexFilter,
limit: QueryLimit,
offset: QueryOffset,
@@ -491,7 +503,9 @@ def get_task_instances(
duration_range,
state,
pool,
+ pool_name_pattern,
queue,
+ queue_name_pattern,
executor,
task_id,
task_display_name_pattern,
@@ -500,6 +514,7 @@ def get_task_instances(
readable_ti_filter,
try_number,
operator,
+ operator_name_pattern,
map_index,
],
order_by=order_by,
diff --git a/airflow-core/src/airflow/ui/openapi-gen/queries/common.ts
b/airflow-core/src/airflow/ui/openapi-gen/queries/common.ts
index 025e0d5507a..e1ca849b1b5 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/common.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/common.ts
@@ -383,7 +383,7 @@ export const UseTaskInstanceServiceGetTaskInstanceKeyFn =
({ dagId, dagRunId, ta
export type TaskInstanceServiceGetMappedTaskInstancesDefaultResponse =
Awaited<ReturnType<typeof TaskInstanceService.getMappedTaskInstances>>;
export type TaskInstanceServiceGetMappedTaskInstancesQueryResult<TData =
TaskInstanceServiceGetMappedTaskInstancesDefaultResponse, TError = unknown> =
UseQueryResult<TData, TError>;
export const useTaskInstanceServiceGetMappedTaskInstancesKey =
"TaskInstanceServiceGetMappedTaskInstances";
-export const UseTaskInstanceServiceGetMappedTaskInstancesKeyFn = ({ dagId,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
orderBy, pool, queue, runAfterGt, runAfterGte, runAfterLt, runAfterLte,
startDateGt, startDateGte, startDateLt, startDateLte, state, taskId, tryNumber,
updatedAtGt, updatedAtGte, updatedAtLt, updatedAtLte [...]
+export const UseTaskInstanceServiceGetMappedTaskInstancesKeyFn = ({ dagId,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
operatorNamePattern, orderBy, pool, poolNamePattern, queue, queueNamePattern,
runAfterGt, runAfterGte, runAfterLt, runAfterLte, startDateGt, startDateGte,
startDateLt, startDateLte, state, taskId, tryNumb [...]
dagId: string;
dagRunId: string;
durationGt?: number;
@@ -403,9 +403,12 @@ export const
UseTaskInstanceServiceGetMappedTaskInstancesKeyFn = ({ dagId, dagRu
mapIndex?: number[];
offset?: number;
operator?: string[];
+ operatorNamePattern?: string;
orderBy?: string[];
pool?: string[];
+ poolNamePattern?: string;
queue?: string[];
+ queueNamePattern?: string;
runAfterGt?: string;
runAfterGte?: string;
runAfterLt?: string;
@@ -422,7 +425,7 @@ export const
UseTaskInstanceServiceGetMappedTaskInstancesKeyFn = ({ dagId, dagRu
updatedAtLt?: string;
updatedAtLte?: string;
versionNumber?: number[];
-}, queryKey?: Array<unknown>) =>
[useTaskInstanceServiceGetMappedTaskInstancesKey, ...(queryKey ?? [{ dagId,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
orderBy, pool, queue, runAfterGt, runAfterGte, runAfterLt, runAfterLte,
startDateGt, startDateGte, startDateLt, startDateLte, state, taskId, tryNumber,
updatedAtGt, updat [...]
+}, queryKey?: Array<unknown>) =>
[useTaskInstanceServiceGetMappedTaskInstancesKey, ...(queryKey ?? [{ dagId,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
operatorNamePattern, orderBy, pool, poolNamePattern, queue, queueNamePattern,
runAfterGt, runAfterGte, runAfterLt, runAfterLte, startDateGt, startDateGte,
startDateLt, st [...]
export type
TaskInstanceServiceGetTaskInstanceDependenciesByMapIndexDefaultResponse =
Awaited<ReturnType<typeof
TaskInstanceService.getTaskInstanceDependenciesByMapIndex>>;
export type
TaskInstanceServiceGetTaskInstanceDependenciesByMapIndexQueryResult<TData =
TaskInstanceServiceGetTaskInstanceDependenciesByMapIndexDefaultResponse, TError
= unknown> = UseQueryResult<TData, TError>;
export const useTaskInstanceServiceGetTaskInstanceDependenciesByMapIndexKey =
"TaskInstanceServiceGetTaskInstanceDependenciesByMapIndex";
@@ -471,7 +474,7 @@ export const
UseTaskInstanceServiceGetMappedTaskInstanceKeyFn = ({ dagId, dagRun
export type TaskInstanceServiceGetTaskInstancesDefaultResponse =
Awaited<ReturnType<typeof TaskInstanceService.getTaskInstances>>;
export type TaskInstanceServiceGetTaskInstancesQueryResult<TData =
TaskInstanceServiceGetTaskInstancesDefaultResponse, TError = unknown> =
UseQueryResult<TData, TError>;
export const useTaskInstanceServiceGetTaskInstancesKey =
"TaskInstanceServiceGetTaskInstances";
-export const UseTaskInstanceServiceGetTaskInstancesKeyFn = ({ dagId,
dagIdPattern, dagRunId, durationGt, durationGte, durationLt, durationLte,
endDateGt, endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
orderBy, pool, queue, runAfterGt, runAfterGte, runAfterLt, runAfterLte,
startDateGt, startDateGte, startDateLt, startDateLte, state,
taskDisplayNamePattern, taskId, tryNumber, updatedAtGt, updated [...]
+export const UseTaskInstanceServiceGetTaskInstancesKeyFn = ({ dagId,
dagIdPattern, dagRunId, durationGt, durationGte, durationLt, durationLte,
endDateGt, endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
operatorNamePattern, orderBy, pool, poolNamePattern, queue, queueNamePattern,
runAfterGt, runAfterGte, runAfterLt, runAfterLte, startDateGt, startDateGte,
startDateLt, startDateLte, state, taskDis [...]
dagId: string;
dagIdPattern?: string;
dagRunId: string;
@@ -492,9 +495,12 @@ export const UseTaskInstanceServiceGetTaskInstancesKeyFn =
({ dagId, dagIdPatter
mapIndex?: number[];
offset?: number;
operator?: string[];
+ operatorNamePattern?: string;
orderBy?: string[];
pool?: string[];
+ poolNamePattern?: string;
queue?: string[];
+ queueNamePattern?: string;
runAfterGt?: string;
runAfterGte?: string;
runAfterLt?: string;
@@ -512,7 +518,7 @@ export const UseTaskInstanceServiceGetTaskInstancesKeyFn =
({ dagId, dagIdPatter
updatedAtLt?: string;
updatedAtLte?: string;
versionNumber?: number[];
-}, queryKey?: Array<unknown>) => [useTaskInstanceServiceGetTaskInstancesKey,
...(queryKey ?? [{ dagId, dagIdPattern, dagRunId, durationGt, durationGte,
durationLt, durationLte, endDateGt, endDateGte, endDateLt, endDateLte,
executor, limit, logicalDateGt, logicalDateGte, logicalDateLt, logicalDateLte,
mapIndex, offset, operator, orderBy, pool, queue, runAfterGt, runAfterGte,
runAfterLt, runAfterLte, startDateGt, startDateGte, startDateLt, startDateLte,
state, taskDisplayNamePattern, taskI [...]
+}, queryKey?: Array<unknown>) => [useTaskInstanceServiceGetTaskInstancesKey,
...(queryKey ?? [{ dagId, dagIdPattern, dagRunId, durationGt, durationGte,
durationLt, durationLte, endDateGt, endDateGte, endDateLt, endDateLte,
executor, limit, logicalDateGt, logicalDateGte, logicalDateLt, logicalDateLte,
mapIndex, offset, operator, operatorNamePattern, orderBy, pool,
poolNamePattern, queue, queueNamePattern, runAfterGt, runAfterGte, runAfterLt,
runAfterLte, startDateGt, startDateGte, startDa [...]
export type TaskInstanceServiceGetTaskInstanceTryDetailsDefaultResponse =
Awaited<ReturnType<typeof TaskInstanceService.getTaskInstanceTryDetails>>;
export type TaskInstanceServiceGetTaskInstanceTryDetailsQueryResult<TData =
TaskInstanceServiceGetTaskInstanceTryDetailsDefaultResponse, TError = unknown>
= UseQueryResult<TData, TError>;
export const useTaskInstanceServiceGetTaskInstanceTryDetailsKey =
"TaskInstanceServiceGetTaskInstanceTryDetails";
diff --git a/airflow-core/src/airflow/ui/openapi-gen/queries/ensureQueryData.ts
b/airflow-core/src/airflow/ui/openapi-gen/queries/ensureQueryData.ts
index ee6cc3f6de3..995041a232e 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/ensureQueryData.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/ensureQueryData.ts
@@ -748,11 +748,14 @@ export const
ensureUseTaskInstanceServiceGetTaskInstanceData = (queryClient: Que
* @param data.durationLt
* @param data.state
* @param data.pool
+* @param data.poolNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.queue
+* @param data.queueNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.executor
* @param data.versionNumber
* @param data.tryNumber
* @param data.operator
+* @param data.operatorNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.mapIndex
* @param data.limit
* @param data.offset
@@ -760,7 +763,7 @@ export const
ensureUseTaskInstanceServiceGetTaskInstanceData = (queryClient: Que
* @returns TaskInstanceCollectionResponse Successful Response
* @throws ApiError
*/
-export const ensureUseTaskInstanceServiceGetMappedTaskInstancesData =
(queryClient: QueryClient, { dagId, dagRunId, durationGt, durationGte,
durationLt, durationLte, endDateGt, endDateGte, endDateLt, endDateLte,
executor, limit, logicalDateGt, logicalDateGte, logicalDateLt, logicalDateLte,
mapIndex, offset, operator, orderBy, pool, queue, runAfterGt, runAfterGte,
runAfterLt, runAfterLte, startDateGt, startDateGte, startDateLt, startDateLte,
state, taskId, tryNumber, updatedAtGt, updatedA [...]
+export const ensureUseTaskInstanceServiceGetMappedTaskInstancesData =
(queryClient: QueryClient, { dagId, dagRunId, durationGt, durationGte,
durationLt, durationLte, endDateGt, endDateGte, endDateLt, endDateLte,
executor, limit, logicalDateGt, logicalDateGte, logicalDateLt, logicalDateLte,
mapIndex, offset, operator, operatorNamePattern, orderBy, pool,
poolNamePattern, queue, queueNamePattern, runAfterGt, runAfterGte, runAfterLt,
runAfterLte, startDateGt, startDateGte, startDateLt, start [...]
dagId: string;
dagRunId: string;
durationGt?: number;
@@ -780,9 +783,12 @@ export const
ensureUseTaskInstanceServiceGetMappedTaskInstancesData = (queryClie
mapIndex?: number[];
offset?: number;
operator?: string[];
+ operatorNamePattern?: string;
orderBy?: string[];
pool?: string[];
+ poolNamePattern?: string;
queue?: string[];
+ queueNamePattern?: string;
runAfterGt?: string;
runAfterGte?: string;
runAfterLt?: string;
@@ -799,7 +805,7 @@ export const
ensureUseTaskInstanceServiceGetMappedTaskInstancesData = (queryClie
updatedAtLt?: string;
updatedAtLte?: string;
versionNumber?: number[];
-}) => queryClient.ensureQueryData({ queryKey:
Common.UseTaskInstanceServiceGetMappedTaskInstancesKeyFn({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, orderBy, pool,
queue, runAfterGt, runAfterGte, runAfterLt, runAfterLte, startDateGt,
startDateGte, startDateLt, startDateLte, state, taskId, tryNumber, updatedAtGt,
up [...]
+}) => queryClient.ensureQueryData({ queryKey:
Common.UseTaskInstanceServiceGetMappedTaskInstancesKeyFn({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, operatorNamePattern,
orderBy, pool, poolNamePattern, queue, queueNamePattern, runAfterGt,
runAfterGte, runAfterLt, runAfterLte, startDateGt, startDateGte, startDateLt,
[...]
/**
* Get Task Instance Dependencies
* Get dependencies blocking task from getting scheduled.
@@ -922,11 +928,14 @@ export const
ensureUseTaskInstanceServiceGetMappedTaskInstanceData = (queryClien
* @param data.dagIdPattern SQL LIKE expression — use `%` / `_` wildcards (e.g.
`%customer_%`). Regular expressions are **not** supported.
* @param data.state
* @param data.pool
+* @param data.poolNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.queue
+* @param data.queueNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.executor
* @param data.versionNumber
* @param data.tryNumber
* @param data.operator
+* @param data.operatorNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.mapIndex
* @param data.limit
* @param data.offset
@@ -934,7 +943,7 @@ export const
ensureUseTaskInstanceServiceGetMappedTaskInstanceData = (queryClien
* @returns TaskInstanceCollectionResponse Successful Response
* @throws ApiError
*/
-export const ensureUseTaskInstanceServiceGetTaskInstancesData = (queryClient:
QueryClient, { dagId, dagIdPattern, dagRunId, durationGt, durationGte,
durationLt, durationLte, endDateGt, endDateGte, endDateLt, endDateLte,
executor, limit, logicalDateGt, logicalDateGte, logicalDateLt, logicalDateLte,
mapIndex, offset, operator, orderBy, pool, queue, runAfterGt, runAfterGte,
runAfterLt, runAfterLte, startDateGt, startDateGte, startDateLt, startDateLte,
state, taskDisplayNamePattern, taskId, [...]
+export const ensureUseTaskInstanceServiceGetTaskInstancesData = (queryClient:
QueryClient, { dagId, dagIdPattern, dagRunId, durationGt, durationGte,
durationLt, durationLte, endDateGt, endDateGte, endDateLt, endDateLte,
executor, limit, logicalDateGt, logicalDateGte, logicalDateLt, logicalDateLte,
mapIndex, offset, operator, operatorNamePattern, orderBy, pool,
poolNamePattern, queue, queueNamePattern, runAfterGt, runAfterGte, runAfterLt,
runAfterLte, startDateGt, startDateGte, startDateL [...]
dagId: string;
dagIdPattern?: string;
dagRunId: string;
@@ -955,9 +964,12 @@ export const
ensureUseTaskInstanceServiceGetTaskInstancesData = (queryClient: Qu
mapIndex?: number[];
offset?: number;
operator?: string[];
+ operatorNamePattern?: string;
orderBy?: string[];
pool?: string[];
+ poolNamePattern?: string;
queue?: string[];
+ queueNamePattern?: string;
runAfterGt?: string;
runAfterGte?: string;
runAfterLt?: string;
@@ -975,7 +987,7 @@ export const
ensureUseTaskInstanceServiceGetTaskInstancesData = (queryClient: Qu
updatedAtLt?: string;
updatedAtLte?: string;
versionNumber?: number[];
-}) => queryClient.ensureQueryData({ queryKey:
Common.UseTaskInstanceServiceGetTaskInstancesKeyFn({ dagId, dagIdPattern,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
orderBy, pool, queue, runAfterGt, runAfterGte, runAfterLt, runAfterLte,
startDateGt, startDateGte, startDateLt, startDateLte, state,
taskDisplayNamePattern, ta [...]
+}) => queryClient.ensureQueryData({ queryKey:
Common.UseTaskInstanceServiceGetTaskInstancesKeyFn({ dagId, dagIdPattern,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
operatorNamePattern, orderBy, pool, poolNamePattern, queue, queueNamePattern,
runAfterGt, runAfterGte, runAfterLt, runAfterLte, startDateGt, startDateGte,
star [...]
/**
* Get Task Instance Try Details
* Get task instance details by try number.
diff --git a/airflow-core/src/airflow/ui/openapi-gen/queries/prefetch.ts
b/airflow-core/src/airflow/ui/openapi-gen/queries/prefetch.ts
index 4fe35c323b0..0caf0a4fee4 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/prefetch.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/prefetch.ts
@@ -748,11 +748,14 @@ export const
prefetchUseTaskInstanceServiceGetTaskInstance = (queryClient: Query
* @param data.durationLt
* @param data.state
* @param data.pool
+* @param data.poolNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.queue
+* @param data.queueNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.executor
* @param data.versionNumber
* @param data.tryNumber
* @param data.operator
+* @param data.operatorNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.mapIndex
* @param data.limit
* @param data.offset
@@ -760,7 +763,7 @@ export const prefetchUseTaskInstanceServiceGetTaskInstance
= (queryClient: Query
* @returns TaskInstanceCollectionResponse Successful Response
* @throws ApiError
*/
-export const prefetchUseTaskInstanceServiceGetMappedTaskInstances =
(queryClient: QueryClient, { dagId, dagRunId, durationGt, durationGte,
durationLt, durationLte, endDateGt, endDateGte, endDateLt, endDateLte,
executor, limit, logicalDateGt, logicalDateGte, logicalDateLt, logicalDateLte,
mapIndex, offset, operator, orderBy, pool, queue, runAfterGt, runAfterGte,
runAfterLt, runAfterLte, startDateGt, startDateGte, startDateLt, startDateLte,
state, taskId, tryNumber, updatedAtGt, updatedAtG [...]
+export const prefetchUseTaskInstanceServiceGetMappedTaskInstances =
(queryClient: QueryClient, { dagId, dagRunId, durationGt, durationGte,
durationLt, durationLte, endDateGt, endDateGte, endDateLt, endDateLte,
executor, limit, logicalDateGt, logicalDateGte, logicalDateLt, logicalDateLte,
mapIndex, offset, operator, operatorNamePattern, orderBy, pool,
poolNamePattern, queue, queueNamePattern, runAfterGt, runAfterGte, runAfterLt,
runAfterLte, startDateGt, startDateGte, startDateLt, startDa [...]
dagId: string;
dagRunId: string;
durationGt?: number;
@@ -780,9 +783,12 @@ export const
prefetchUseTaskInstanceServiceGetMappedTaskInstances = (queryClient
mapIndex?: number[];
offset?: number;
operator?: string[];
+ operatorNamePattern?: string;
orderBy?: string[];
pool?: string[];
+ poolNamePattern?: string;
queue?: string[];
+ queueNamePattern?: string;
runAfterGt?: string;
runAfterGte?: string;
runAfterLt?: string;
@@ -799,7 +805,7 @@ export const
prefetchUseTaskInstanceServiceGetMappedTaskInstances = (queryClient
updatedAtLt?: string;
updatedAtLte?: string;
versionNumber?: number[];
-}) => queryClient.prefetchQuery({ queryKey:
Common.UseTaskInstanceServiceGetMappedTaskInstancesKeyFn({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, orderBy, pool,
queue, runAfterGt, runAfterGte, runAfterLt, runAfterLte, startDateGt,
startDateGte, startDateLt, startDateLte, state, taskId, tryNumber, updatedAtGt,
upda [...]
+}) => queryClient.prefetchQuery({ queryKey:
Common.UseTaskInstanceServiceGetMappedTaskInstancesKeyFn({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, operatorNamePattern,
orderBy, pool, poolNamePattern, queue, queueNamePattern, runAfterGt,
runAfterGte, runAfterLt, runAfterLte, startDateGt, startDateGte, startDateLt, s
[...]
/**
* Get Task Instance Dependencies
* Get dependencies blocking task from getting scheduled.
@@ -922,11 +928,14 @@ export const
prefetchUseTaskInstanceServiceGetMappedTaskInstance = (queryClient:
* @param data.dagIdPattern SQL LIKE expression — use `%` / `_` wildcards (e.g.
`%customer_%`). Regular expressions are **not** supported.
* @param data.state
* @param data.pool
+* @param data.poolNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.queue
+* @param data.queueNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.executor
* @param data.versionNumber
* @param data.tryNumber
* @param data.operator
+* @param data.operatorNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.mapIndex
* @param data.limit
* @param data.offset
@@ -934,7 +943,7 @@ export const
prefetchUseTaskInstanceServiceGetMappedTaskInstance = (queryClient:
* @returns TaskInstanceCollectionResponse Successful Response
* @throws ApiError
*/
-export const prefetchUseTaskInstanceServiceGetTaskInstances = (queryClient:
QueryClient, { dagId, dagIdPattern, dagRunId, durationGt, durationGte,
durationLt, durationLte, endDateGt, endDateGte, endDateLt, endDateLte,
executor, limit, logicalDateGt, logicalDateGte, logicalDateLt, logicalDateLte,
mapIndex, offset, operator, orderBy, pool, queue, runAfterGt, runAfterGte,
runAfterLt, runAfterLte, startDateGt, startDateGte, startDateLt, startDateLte,
state, taskDisplayNamePattern, taskId, tr [...]
+export const prefetchUseTaskInstanceServiceGetTaskInstances = (queryClient:
QueryClient, { dagId, dagIdPattern, dagRunId, durationGt, durationGte,
durationLt, durationLte, endDateGt, endDateGte, endDateLt, endDateLte,
executor, limit, logicalDateGt, logicalDateGte, logicalDateLt, logicalDateLte,
mapIndex, offset, operator, operatorNamePattern, orderBy, pool,
poolNamePattern, queue, queueNamePattern, runAfterGt, runAfterGte, runAfterLt,
runAfterLte, startDateGt, startDateGte, startDateLt, [...]
dagId: string;
dagIdPattern?: string;
dagRunId: string;
@@ -955,9 +964,12 @@ export const
prefetchUseTaskInstanceServiceGetTaskInstances = (queryClient: Quer
mapIndex?: number[];
offset?: number;
operator?: string[];
+ operatorNamePattern?: string;
orderBy?: string[];
pool?: string[];
+ poolNamePattern?: string;
queue?: string[];
+ queueNamePattern?: string;
runAfterGt?: string;
runAfterGte?: string;
runAfterLt?: string;
@@ -975,7 +987,7 @@ export const prefetchUseTaskInstanceServiceGetTaskInstances
= (queryClient: Quer
updatedAtLt?: string;
updatedAtLte?: string;
versionNumber?: number[];
-}) => queryClient.prefetchQuery({ queryKey:
Common.UseTaskInstanceServiceGetTaskInstancesKeyFn({ dagId, dagIdPattern,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
orderBy, pool, queue, runAfterGt, runAfterGte, runAfterLt, runAfterLte,
startDateGt, startDateGte, startDateLt, startDateLte, state,
taskDisplayNamePattern, task [...]
+}) => queryClient.prefetchQuery({ queryKey:
Common.UseTaskInstanceServiceGetTaskInstancesKeyFn({ dagId, dagIdPattern,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
operatorNamePattern, orderBy, pool, poolNamePattern, queue, queueNamePattern,
runAfterGt, runAfterGte, runAfterLt, runAfterLte, startDateGt, startDateGte,
startD [...]
/**
* Get Task Instance Try Details
* Get task instance details by try number.
diff --git a/airflow-core/src/airflow/ui/openapi-gen/queries/queries.ts
b/airflow-core/src/airflow/ui/openapi-gen/queries/queries.ts
index 8bf69d58b01..a3af73a6c7f 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/queries.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/queries.ts
@@ -748,11 +748,14 @@ export const useTaskInstanceServiceGetTaskInstance =
<TData = Common.TaskInstanc
* @param data.durationLt
* @param data.state
* @param data.pool
+* @param data.poolNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.queue
+* @param data.queueNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.executor
* @param data.versionNumber
* @param data.tryNumber
* @param data.operator
+* @param data.operatorNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.mapIndex
* @param data.limit
* @param data.offset
@@ -760,7 +763,7 @@ export const useTaskInstanceServiceGetTaskInstance = <TData
= Common.TaskInstanc
* @returns TaskInstanceCollectionResponse Successful Response
* @throws ApiError
*/
-export const useTaskInstanceServiceGetMappedTaskInstances = <TData =
Common.TaskInstanceServiceGetMappedTaskInstancesDefaultResponse, TError =
unknown, TQueryKey extends Array<unknown> = unknown[]>({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, orderBy, pool,
queue, runAfterGt, runAfterGte, runAfterLt, runAfterLte, [...]
+export const useTaskInstanceServiceGetMappedTaskInstances = <TData =
Common.TaskInstanceServiceGetMappedTaskInstancesDefaultResponse, TError =
unknown, TQueryKey extends Array<unknown> = unknown[]>({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, operatorNamePattern,
orderBy, pool, poolNamePattern, queue, queueNamePat [...]
dagId: string;
dagRunId: string;
durationGt?: number;
@@ -780,9 +783,12 @@ export const useTaskInstanceServiceGetMappedTaskInstances
= <TData = Common.Task
mapIndex?: number[];
offset?: number;
operator?: string[];
+ operatorNamePattern?: string;
orderBy?: string[];
pool?: string[];
+ poolNamePattern?: string;
queue?: string[];
+ queueNamePattern?: string;
runAfterGt?: string;
runAfterGte?: string;
runAfterLt?: string;
@@ -799,7 +805,7 @@ export const useTaskInstanceServiceGetMappedTaskInstances =
<TData = Common.Task
updatedAtLt?: string;
updatedAtLte?: string;
versionNumber?: number[];
-}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseTaskInstanceServiceGetMappedTaskInstancesKeyFn({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, orderBy, pool,
queue, runAfterGt, runAfterGte, runAfterLt, runAfterLte, start [...]
+}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseTaskInstanceServiceGetMappedTaskInstancesKeyFn({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, operatorNamePattern,
orderBy, pool, poolNamePattern, queue, queueNamePattern, [...]
/**
* Get Task Instance Dependencies
* Get dependencies blocking task from getting scheduled.
@@ -922,11 +928,14 @@ export const useTaskInstanceServiceGetMappedTaskInstance
= <TData = Common.TaskI
* @param data.dagIdPattern SQL LIKE expression — use `%` / `_` wildcards (e.g.
`%customer_%`). Regular expressions are **not** supported.
* @param data.state
* @param data.pool
+* @param data.poolNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.queue
+* @param data.queueNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.executor
* @param data.versionNumber
* @param data.tryNumber
* @param data.operator
+* @param data.operatorNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.mapIndex
* @param data.limit
* @param data.offset
@@ -934,7 +943,7 @@ export const useTaskInstanceServiceGetMappedTaskInstance =
<TData = Common.TaskI
* @returns TaskInstanceCollectionResponse Successful Response
* @throws ApiError
*/
-export const useTaskInstanceServiceGetTaskInstances = <TData =
Common.TaskInstanceServiceGetTaskInstancesDefaultResponse, TError = unknown,
TQueryKey extends Array<unknown> = unknown[]>({ dagId, dagIdPattern, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, orderBy, pool,
queue, runAfterGt, runAfterGte, runAfterLt, runAfterLte [...]
+export const useTaskInstanceServiceGetTaskInstances = <TData =
Common.TaskInstanceServiceGetTaskInstancesDefaultResponse, TError = unknown,
TQueryKey extends Array<unknown> = unknown[]>({ dagId, dagIdPattern, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, operatorNamePattern,
orderBy, pool, poolNamePattern, queue, queueNameP [...]
dagId: string;
dagIdPattern?: string;
dagRunId: string;
@@ -955,9 +964,12 @@ export const useTaskInstanceServiceGetTaskInstances =
<TData = Common.TaskInstan
mapIndex?: number[];
offset?: number;
operator?: string[];
+ operatorNamePattern?: string;
orderBy?: string[];
pool?: string[];
+ poolNamePattern?: string;
queue?: string[];
+ queueNamePattern?: string;
runAfterGt?: string;
runAfterGte?: string;
runAfterLt?: string;
@@ -975,7 +987,7 @@ export const useTaskInstanceServiceGetTaskInstances =
<TData = Common.TaskInstan
updatedAtLt?: string;
updatedAtLte?: string;
versionNumber?: number[];
-}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseTaskInstanceServiceGetTaskInstancesKeyFn({ dagId, dagIdPattern,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
orderBy, pool, queue, runAfterGt, runAfterGte, runAfterLt, runAfterLt [...]
+}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useQuery<TData, TError>({ queryKey:
Common.UseTaskInstanceServiceGetTaskInstancesKeyFn({ dagId, dagIdPattern,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
operatorNamePattern, orderBy, pool, poolNamePattern, queue, queueName [...]
/**
* Get Task Instance Try Details
* Get task instance details by try number.
diff --git a/airflow-core/src/airflow/ui/openapi-gen/queries/suspense.ts
b/airflow-core/src/airflow/ui/openapi-gen/queries/suspense.ts
index 44b5d7c99e1..e8a53657dd1 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/queries/suspense.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/queries/suspense.ts
@@ -748,11 +748,14 @@ export const
useTaskInstanceServiceGetTaskInstanceSuspense = <TData = Common.Tas
* @param data.durationLt
* @param data.state
* @param data.pool
+* @param data.poolNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.queue
+* @param data.queueNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.executor
* @param data.versionNumber
* @param data.tryNumber
* @param data.operator
+* @param data.operatorNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.mapIndex
* @param data.limit
* @param data.offset
@@ -760,7 +763,7 @@ export const useTaskInstanceServiceGetTaskInstanceSuspense
= <TData = Common.Tas
* @returns TaskInstanceCollectionResponse Successful Response
* @throws ApiError
*/
-export const useTaskInstanceServiceGetMappedTaskInstancesSuspense = <TData =
Common.TaskInstanceServiceGetMappedTaskInstancesDefaultResponse, TError =
unknown, TQueryKey extends Array<unknown> = unknown[]>({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, orderBy, pool,
queue, runAfterGt, runAfterGte, runAfterLt, runAf [...]
+export const useTaskInstanceServiceGetMappedTaskInstancesSuspense = <TData =
Common.TaskInstanceServiceGetMappedTaskInstancesDefaultResponse, TError =
unknown, TQueryKey extends Array<unknown> = unknown[]>({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, operatorNamePattern,
orderBy, pool, poolNamePattern, queue, queu [...]
dagId: string;
dagRunId: string;
durationGt?: number;
@@ -780,9 +783,12 @@ export const
useTaskInstanceServiceGetMappedTaskInstancesSuspense = <TData = Com
mapIndex?: number[];
offset?: number;
operator?: string[];
+ operatorNamePattern?: string;
orderBy?: string[];
pool?: string[];
+ poolNamePattern?: string;
queue?: string[];
+ queueNamePattern?: string;
runAfterGt?: string;
runAfterGte?: string;
runAfterLt?: string;
@@ -799,7 +805,7 @@ export const
useTaskInstanceServiceGetMappedTaskInstancesSuspense = <TData = Com
updatedAtLt?: string;
updatedAtLte?: string;
versionNumber?: number[];
-}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseTaskInstanceServiceGetMappedTaskInstancesKeyFn({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, orderBy, pool,
queue, runAfterGt, runAfterGte, runAfterLt, runAfterLt [...]
+}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseTaskInstanceServiceGetMappedTaskInstancesKeyFn({ dagId, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, operatorNamePattern,
orderBy, pool, poolNamePattern, queue, queueName [...]
/**
* Get Task Instance Dependencies
* Get dependencies blocking task from getting scheduled.
@@ -922,11 +928,14 @@ export const
useTaskInstanceServiceGetMappedTaskInstanceSuspense = <TData = Comm
* @param data.dagIdPattern SQL LIKE expression — use `%` / `_` wildcards (e.g.
`%customer_%`). Regular expressions are **not** supported.
* @param data.state
* @param data.pool
+* @param data.poolNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.queue
+* @param data.queueNamePattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.executor
* @param data.versionNumber
* @param data.tryNumber
* @param data.operator
+* @param data.operatorNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.mapIndex
* @param data.limit
* @param data.offset
@@ -934,7 +943,7 @@ export const
useTaskInstanceServiceGetMappedTaskInstanceSuspense = <TData = Comm
* @returns TaskInstanceCollectionResponse Successful Response
* @throws ApiError
*/
-export const useTaskInstanceServiceGetTaskInstancesSuspense = <TData =
Common.TaskInstanceServiceGetTaskInstancesDefaultResponse, TError = unknown,
TQueryKey extends Array<unknown> = unknown[]>({ dagId, dagIdPattern, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, orderBy, pool,
queue, runAfterGt, runAfterGte, runAfterLt, run [...]
+export const useTaskInstanceServiceGetTaskInstancesSuspense = <TData =
Common.TaskInstanceServiceGetTaskInstancesDefaultResponse, TError = unknown,
TQueryKey extends Array<unknown> = unknown[]>({ dagId, dagIdPattern, dagRunId,
durationGt, durationGte, durationLt, durationLte, endDateGt, endDateGte,
endDateLt, endDateLte, executor, limit, logicalDateGt, logicalDateGte,
logicalDateLt, logicalDateLte, mapIndex, offset, operator, operatorNamePattern,
orderBy, pool, poolNamePattern, queue, qu [...]
dagId: string;
dagIdPattern?: string;
dagRunId: string;
@@ -955,9 +964,12 @@ export const
useTaskInstanceServiceGetTaskInstancesSuspense = <TData = Common.Ta
mapIndex?: number[];
offset?: number;
operator?: string[];
+ operatorNamePattern?: string;
orderBy?: string[];
pool?: string[];
+ poolNamePattern?: string;
queue?: string[];
+ queueNamePattern?: string;
runAfterGt?: string;
runAfterGte?: string;
runAfterLt?: string;
@@ -975,7 +987,7 @@ export const useTaskInstanceServiceGetTaskInstancesSuspense
= <TData = Common.Ta
updatedAtLt?: string;
updatedAtLte?: string;
versionNumber?: number[];
-}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseTaskInstanceServiceGetTaskInstancesKeyFn({ dagId, dagIdPattern,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
orderBy, pool, queue, runAfterGt, runAfterGte, runAfterLt, ru [...]
+}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData, TError>,
"queryKey" | "queryFn">) => useSuspenseQuery<TData, TError>({ queryKey:
Common.UseTaskInstanceServiceGetTaskInstancesKeyFn({ dagId, dagIdPattern,
dagRunId, durationGt, durationGte, durationLt, durationLte, endDateGt,
endDateGte, endDateLt, endDateLte, executor, limit, logicalDateGt,
logicalDateGte, logicalDateLt, logicalDateLte, mapIndex, offset, operator,
operatorNamePattern, orderBy, pool, poolNamePattern, queue, q [...]
/**
* Get Task Instance Try Details
* Get task instance details by try number.
diff --git a/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts
b/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts
index 31c928e52a7..c2b866d87ce 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/requests/services.gen.ts
@@ -2035,11 +2035,14 @@ export class TaskInstanceService {
* @param data.durationLt
* @param data.state
* @param data.pool
+ * @param data.poolNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.queue
+ * @param data.queueNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.executor
* @param data.versionNumber
* @param data.tryNumber
* @param data.operator
+ * @param data.operatorNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.mapIndex
* @param data.limit
* @param data.offset
@@ -2083,11 +2086,14 @@ export class TaskInstanceService {
duration_lt: data.durationLt,
state: data.state,
pool: data.pool,
+ pool_name_pattern: data.poolNamePattern,
queue: data.queue,
+ queue_name_pattern: data.queueNamePattern,
executor: data.executor,
version_number: data.versionNumber,
try_number: data.tryNumber,
operator: data.operator,
+ operator_name_pattern: data.operatorNamePattern,
map_index: data.mapIndex,
limit: data.limit,
offset: data.offset,
@@ -2332,11 +2338,14 @@ export class TaskInstanceService {
* @param data.dagIdPattern SQL LIKE expression — use `%` / `_` wildcards
(e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.state
* @param data.pool
+ * @param data.poolNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.queue
+ * @param data.queueNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.executor
* @param data.versionNumber
* @param data.tryNumber
* @param data.operator
+ * @param data.operatorNamePattern SQL LIKE expression — use `%` / `_`
wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
* @param data.mapIndex
* @param data.limit
* @param data.offset
@@ -2382,11 +2391,14 @@ export class TaskInstanceService {
dag_id_pattern: data.dagIdPattern,
state: data.state,
pool: data.pool,
+ pool_name_pattern: data.poolNamePattern,
queue: data.queue,
+ queue_name_pattern: data.queueNamePattern,
executor: data.executor,
version_number: data.versionNumber,
try_number: data.tryNumber,
operator: data.operator,
+ operator_name_pattern: data.operatorNamePattern,
map_index: data.mapIndex,
limit: data.limit,
offset: data.offset,
diff --git a/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts
b/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts
index df2d503061e..2b814b1ebea 100644
--- a/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts
+++ b/airflow-core/src/airflow/ui/openapi-gen/requests/types.gen.ts
@@ -2737,12 +2737,24 @@ export type GetMappedTaskInstancesData = {
mapIndex?: Array<(number)>;
offset?: number;
operator?: Array<(string)>;
+ /**
+ * SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`).
Regular expressions are **not** supported.
+ */
+ operatorNamePattern?: string | null;
/**
* Attributes to order by, multi criteria sort is supported. Prefix with
`-` for descending order. Supported attributes: `id, state, duration,
start_date, end_date, map_index, try_number, logical_date, run_after,
data_interval_start, data_interval_end, rendered_map_index, operator,
run_after, logical_date, data_interval_start, data_interval_end`
*/
orderBy?: Array<(string)>;
pool?: Array<(string)>;
+ /**
+ * SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`).
Regular expressions are **not** supported.
+ */
+ poolNamePattern?: string | null;
queue?: Array<(string)>;
+ /**
+ * SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`).
Regular expressions are **not** supported.
+ */
+ queueNamePattern?: string | null;
runAfterGt?: string | null;
runAfterGte?: string | null;
runAfterLt?: string | null;
@@ -2843,12 +2855,24 @@ export type GetTaskInstancesData = {
mapIndex?: Array<(number)>;
offset?: number;
operator?: Array<(string)>;
+ /**
+ * SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`).
Regular expressions are **not** supported.
+ */
+ operatorNamePattern?: string | null;
/**
* Attributes to order by, multi criteria sort is supported. Prefix with
`-` for descending order. Supported attributes: `id, state, duration,
start_date, end_date, map_index, try_number, logical_date, run_after,
data_interval_start, data_interval_end, rendered_map_index, operator,
logical_date, run_after, data_interval_start, data_interval_end`
*/
orderBy?: Array<(string)>;
pool?: Array<(string)>;
+ /**
+ * SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`).
Regular expressions are **not** supported.
+ */
+ poolNamePattern?: string | null;
queue?: Array<(string)>;
+ /**
+ * SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`).
Regular expressions are **not** supported.
+ */
+ queueNamePattern?: string | null;
runAfterGt?: string | null;
runAfterGte?: string | null;
runAfterLt?: string | null;
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
index f1c6564e242..f36cf0947d0 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
@@ -1128,6 +1128,18 @@ class TestGetTaskInstances(TestTaskInstanceEndpoint):
3,
id="test pool filter ~",
),
+ pytest.param(
+ [
+ {"pool": "test_pool_1"},
+ {"pool": "test_pool_2"},
+ {"pool": "test_pool_3"},
+ ],
+ True,
+ "/dags/~/dagRuns/~/taskInstances",
+ {"pool_name_pattern": "test_pool"},
+ 3,
+ id="test pool_name_pattern filter",
+ ),
pytest.param(
[
{"queue": "test_queue_1"},
@@ -1154,6 +1166,20 @@ class TestGetTaskInstances(TestTaskInstanceEndpoint):
3,
id="test queue filter ~",
),
+ pytest.param(
+ [
+ {"queue": "test_queue_1"},
+ {"queue": "test_queue_2"},
+ {"queue": "test_queue_3"},
+ {"queue": "other_queue_3"},
+ {"queue": "other_queue_3"},
+ ],
+ True,
+ "/dags/~/dagRuns/~/taskInstances",
+ {"queue_name_pattern": "test"},
+ 3,
+ id="test queue_name_pattern filter",
+ ),
pytest.param(
[
{"executor": "test_exec_1"},
@@ -1264,6 +1290,20 @@ class TestGetTaskInstances(TestTaskInstanceEndpoint):
3,
id="test operator type filter filter",
),
+ pytest.param(
+ [
+ {"custom_operator_name": "CustomFirstOperator"},
+ {"custom_operator_name": "CustomSecondOperator"},
+ {"custom_operator_name": "SecondOperator"},
+ {"custom_operator_name": "ThirdOperator"},
+ {"custom_operator_name": "ThirdOperator"},
+ ],
+ True,
+ "/dags/~/dagRuns/~/taskInstances",
+ {"operator_name_pattern": "Custom"},
+ 2,
+ id="test operator_name_pattern filter",
+ ),
pytest.param(
[
{"map_index": 0},
