Use cancellation on join here too

amphp · Mar 2, 2023 · 409a8f2 · 409a8f2
1 parent a072e63
commit 409a8f2
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/Worker/Internal/ContextWorker.php b/src/Worker/Internal/ContextWorker.php
@@ -149,8 +149,7 @@ public function submit(Task $task, ?Cancellation $cancellation = null): Executio
         } catch (ChannelException $exception) {
             try {
                 $exception = new WorkerException("The worker exited unexpectedly", 0, $exception);
-                async($this->context->join(...))
-                    ->await(new TimeoutCancellation(self::ERROR_TIMEOUT));
+                $this->context->join(new TimeoutCancellation(self::ERROR_TIMEOUT));
             } catch (CancelledException) {
                 $this->kill();
             } catch (\Throwable $exception) {