diff --git a/core/trino-main/src/main/java/io/trino/execution/scheduler/SqlQueryScheduler.java b/core/trino-main/src/main/java/io/trino/execution/scheduler/SqlQueryScheduler.java
index 5e34931fca1f..1d57d4096744 100644
--- a/core/trino-main/src/main/java/io/trino/execution/scheduler/SqlQueryScheduler.java
+++ b/core/trino-main/src/main/java/io/trino/execution/scheduler/SqlQueryScheduler.java
@@ -289,9 +289,9 @@ else if (state == QueryState.FAILED) {
             queryStateMachine.updateQueryInfo(Optional.ofNullable(getStageInfo()));
         });
 
-        coordinatorStagesScheduler.schedule();
-
         Optional<DistributedStagesScheduler> distributedStagesScheduler = createDistributedStagesScheduler(currentAttempt.get());
+
+        coordinatorStagesScheduler.schedule();
         distributedStagesScheduler.ifPresent(scheduler -> distributedStagesSchedulingTask = executor.submit(scheduler::schedule, null));
     }