This is an automated email from the ASF dual-hosted git repository.
choo121600 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 282eb9b3641 E2E: Parallelize fixture Dag run cleanup (#64670)
282eb9b3641 is described below
commit 282eb9b3641f715388de249b91ab6f3f1e05abe6
Author: Yeonguk Choo <[email protected]>
AuthorDate: Tue Apr 14 18:03:01 2026 +0900
E2E: Parallelize fixture Dag run cleanup (#64670)
---
airflow-core/src/airflow/ui/tests/e2e/fixtures/data.ts | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/airflow-core/src/airflow/ui/tests/e2e/fixtures/data.ts
b/airflow-core/src/airflow/ui/tests/e2e/fixtures/data.ts
index ad1e6d8b7b6..4c8537f45e9 100644
--- a/airflow-core/src/airflow/ui/tests/e2e/fixtures/data.ts
+++ b/airflow-core/src/airflow/ui/tests/e2e/fixtures/data.ts
@@ -98,9 +98,7 @@ async function cleanupMultipleRuns(
request: APIRequestContext,
runs: Array<{ dagId: string; runId: string }>,
): Promise<void> {
- for (const { dagId, runId } of runs) {
- await safeCleanupDagRun(request, dagId, runId);
- }
+ await Promise.all(runs.map(({ dagId, runId }) => safeCleanupDagRun(request,
dagId, runId)));
}
export const test = base.extend<DataTestFixtures, DataWorkerFixtures>({
