Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 10 additions & 1 deletion airflow-core/src/airflow/ui/src/queries/useGridRuns.ts
Original file line number Diff line number Diff line change
Expand Up @@ -56,6 +56,15 @@ export const useGridRuns = ({
value: runIdPattern,
});

// Advanced-search toggle picks between the substring ``triggeringUser`` and the
// index-friendly ``triggeringUserPrefix`` variants of the Triggering User filter.
const triggeringUserArg = useAdvancedSearchArg({
patternApiKey: "triggeringUser",
prefixApiKey: "triggeringUserPrefix",
storageKey: SearchParamsKeys.TRIGGERING_USER_NAME_PATTERN,
value: triggeringUser,
});

const { data: GridRuns, ...rest } = useGridServiceGetGridRuns(
{
dagId,
Expand All @@ -67,7 +76,7 @@ export const useGridRuns = ({
...runIdPatternArg,
runType: runType ? [runType] : undefined,
state: dagRunState ? [dagRunState] : undefined,
triggeringUser: triggeringUser ?? undefined,
...triggeringUserArg,
},
undefined,
{
Expand Down
11 changes: 10 additions & 1 deletion airflow-core/src/airflow/ui/src/queries/useGridStructure.ts
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,15 @@ export const useGridStructure = ({
value: runIdPattern,
});

// Advanced-search toggle picks between the substring ``triggeringUser`` and the
// index-friendly ``triggeringUserPrefix`` variants of the Triggering User filter.
const triggeringUserArg = useAdvancedSearchArg({
patternApiKey: "triggeringUser",
prefixApiKey: "triggeringUserPrefix",
storageKey: SearchParamsKeys.TRIGGERING_USER_NAME_PATTERN,
value: triggeringUser,
});

// This is necessary for keepPreviousData
const { data: dagStructure, ...rest } = useGridServiceGetDagStructure(
{
Expand All @@ -72,7 +81,7 @@ export const useGridStructure = ({
...runIdPatternArg,
runType: runType ? [runType] : undefined,
state: dagRunState ? [dagRunState] : undefined,
triggeringUser: triggeringUser ?? undefined,
...triggeringUserArg,
},
undefined,
{
Expand Down
Loading