Ignore any incoming jobs once the worker is shutting down

bzikarsky · Apr 28, 2021 · d022b90 · d022b90
1 parent 2230ef3
commit d022b90
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/Worker.php b/src/Worker.php
@@ -296,6 +296,11 @@ protected function handleUniqueJob(CommandInterface $command): void
 
     protected function processJob(JobInterface $job): void
     {
+        // If we are shutting down, ignore the job, we likely already unregistered the function
+        if ($this->shutdownPromise !== null) {
+            return;
+        }
+
         if (!isset($this->functions[$job->getFunction()])) {
             throw new LogicException("Got job for unknown function {$job->getFunction()}");
         }