From 6837810bd580753dbfdc5cdab6ffb34b8b781a33 Mon Sep 17 00:00:00 2001 From: probe Date: Thu, 9 Jul 2026 17:19:17 -0700 Subject: [PATCH 1/2] refactor(amber): remove dead WorkflowWorker.handleActorCommand --- .../amber/engine/architecture/worker/WorkflowWorker.scala | 5 ----- 1 file changed, 5 deletions(-) diff --git a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/WorkflowWorker.scala b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/WorkflowWorker.scala index 51bf59b2f1f..00ca8911b7f 100644 --- a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/WorkflowWorker.scala +++ b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/WorkflowWorker.scala @@ -127,11 +127,6 @@ class WorkflowWorker( t.closure(this) } - def handleActorCommand: Receive = { - case c: ActorCommand => - println(c) - } - override def preRestart(reason: Throwable, message: Option[Any]): Unit = { super.preRestart(reason, message) logger.error(s"Encountered fatal error, worker is shutting done.", reason) From 44cf0a2e0e47bb8e7a68db430ed4d7fbfd2dcbe9 Mon Sep 17 00:00:00 2001 From: Xinyuan Lin Date: Thu, 9 Jul 2026 17:23:41 -0700 Subject: [PATCH 2/2] Potential fix for pull request finding Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com> Signed-off-by: Xinyuan Lin --- .../amber/engine/architecture/worker/WorkflowWorker.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/WorkflowWorker.scala b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/WorkflowWorker.scala index 00ca8911b7f..99f10050f39 100644 --- a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/WorkflowWorker.scala +++ b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/WorkflowWorker.scala @@ -129,7 +129,7 @@ class WorkflowWorker( override def preRestart(reason: Throwable, message: Option[Any]): Unit = { super.preRestart(reason, message) - logger.error(s"Encountered fatal error, worker is shutting done.", reason) + logger.error(s"Encountered fatal error, worker is shutting down.", reason) postStop() }