From d5ece5daca8358bf4705f609d77df4b6f647de11 Mon Sep 17 00:00:00 2001
From: Dmitri Bourlatchkov <dmitri.bourlatchkov@gmail.com>
Date: Mon, 5 Jan 2026 14:31:02 -0500
Subject: [PATCH] Fix error handler parameters in TaskExecutorImpl

Use correct exception variable inside `CompletableFuture.exceptionallyComposeAsync()`
---
 .../java/org/apache/polaris/service/task/TaskExecutorImpl.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/runtime/service/src/main/java/org/apache/polaris/service/task/TaskExecutorImpl.java b/runtime/service/src/main/java/org/apache/polaris/service/task/TaskExecutorImpl.java
index ca25b93578..a30fdac883 100644
--- a/runtime/service/src/main/java/org/apache/polaris/service/task/TaskExecutorImpl.java
+++ b/runtime/service/src/main/java/org/apache/polaris/service/task/TaskExecutorImpl.java
@@ -184,7 +184,7 @@ public void addTaskHandlerContext(long taskEntityId, CallContext callContext) {
         .exceptionallyComposeAsync(
             (t) -> {
               LOGGER.warn("Failed to handle task entity id {}", taskEntityId, t);
-              errorHandler.ifPresent(h -> h.accept(taskEntityId, false, e));
+              errorHandler.ifPresent(h -> h.accept(taskEntityId, false, t));
               return tryHandleTask(taskEntityId, callContext, eventMetadata, t, attempt + 1);
             },
             CompletableFuture.delayedExecutor(