diff --git a/src/Services/QueuedJobService.php b/src/Services/QueuedJobService.php
index 8c18aa91..2bab4e66 100644
--- a/src/Services/QueuedJobService.php
+++ b/src/Services/QueuedJobService.php
@@ -680,7 +680,7 @@ public function runJob($jobId)
                     $jobDescriptor->write();
                 }
 
-                if (!$broken) {
+                if ($job->jobFinished()) {
                     $job->afterComplete();
                     $jobDescriptor->cleanupJob();
                 }