We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0b050b1 commit 9098256Copy full SHA for 9098256
src/Internal/ContextClusterWorker.php
@@ -109,7 +109,13 @@ public function run(): void
109
};
110
}
111
112
- $this->joinFuture->await(new TimeoutCancellation(ClusterWatcher::WORKER_TIMEOUT));
+ try {
113
+ $this->joinFuture->await(new TimeoutCancellation(ClusterWatcher::WORKER_TIMEOUT));
114
+ } catch (CancelledException) {
115
+ $this->close();
116
+ // Give it a second to reap the result. Generally this never should time out, unless something is seriously broken.
117
+ $this->joinFuture->await(new TimeoutCancellation(1));
118
+ }
119
} catch (\Throwable $exception) {
120
$this->joinFuture->ignore();
121
throw $exception;
0 commit comments