add option to trigger an oncompletion handler if available, once the …

…job is completed
Symplicity · Sep 9, 2024 · 8d8240a · 8d8240a
1 parent 42c6a5b
commit 8d8240a
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/lib/Resque/Worker.php b/lib/Resque/Worker.php
@@ -232,8 +232,16 @@ public function work($interval = Resque::DEFAULT_INTERVAL, $blocking = false)
 					pcntl_signal_dispatch();
 					sleep(1);
 				}
-				$exitStatus = 0;
+
 				if (pcntl_wifexited($status) === true) {
+					// Job is completed, trigger completion listeners
+					$jobArgs = $job->getArguments();
+					if (!empty($jobArgs['onCompletionHandler'])) {
+						Resque_Event::trigger('onCompletion', array(
+							'job' => $job,
+						));
+					}
+
 					$exitStatus = pcntl_wexitstatus($status);
 					if($exitStatus !== 0) {
 						$job->fail(new Resque_Job_DirtyExitException(