Report ExitFailures from cluster worker exits

amphp · Dec 21, 2024 · f08710e · f08710e
1 parent 0b050b1
commit f08710e
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/Internal/ContextClusterWorker.php b/src/Internal/ContextClusterWorker.php
@@ -109,7 +109,14 @@ public function run(): void
                 };
             }
 
-            $this->joinFuture->await(new TimeoutCancellation(ClusterWatcher::WORKER_TIMEOUT));
+            try {
+                $this->joinFuture->await(new TimeoutCancellation(ClusterWatcher::WORKER_TIMEOUT));
+            } catch (CancelledException $e) {
+                $this->close();
+                // Give it a second to reap the result. Generally this never should time out, unless something is seriously broken.
+                $this->joinFuture->await(new TimeoutCancellation(1));
+                throw $e;
+            }
         } catch (\Throwable $exception) {
             $this->joinFuture->ignore();
             throw $exception;