@@ -365,16 +365,7 @@ protected function _runJob($scheduledTime, $currentTime, $jobConfig, $schedule,
365
365
);
366
366
}
367
367
368
- if (!isset ($ this ->originalProcessTitle )) {
369
- $ this ->originalProcessTitle = PHP_BINARY . ' ' . implode (' ' , $ this ->environment ->getServer ('argv ' ));
370
- }
371
-
372
- if (strpos ($ this ->originalProcessTitle , " --group= $ groupId " ) !== false ) {
373
- // Group is already shown, so no need to include here in duplicate
374
- cli_set_process_title ($ this ->originalProcessTitle . " # job: $ jobCode " );
375
- } else {
376
- cli_set_process_title ($ this ->originalProcessTitle . " # group: $ groupId, job: $ jobCode " );
377
- }
368
+ $ this ->setProcessTitle ($ jobCode , $ groupId );
378
369
379
370
$ schedule ->setExecutedAt (date ('Y-m-d H:i:s ' , $ this ->dateTime ->gmtTimestamp ()));
380
371
$ this ->retrier ->execute (
@@ -954,4 +945,24 @@ function () use ($scheduleResource, $where) {
954
945
$ scheduleResource ->getConnection ()
955
946
);
956
947
}
948
+
949
+ /**
950
+ * Set the process title to include the job code and group
951
+ *
952
+ * @param string $jobCode
953
+ * @param string $groupId
954
+ */
955
+ private function setProcessTitle (string $ jobCode , string $ groupId ): void
956
+ {
957
+ if (!isset ($ this ->originalProcessTitle )) {
958
+ $ this ->originalProcessTitle = PHP_BINARY . ' ' . implode (' ' , $ this ->environment ->getServer ('argv ' ));
959
+ }
960
+
961
+ if (strpos ($ this ->originalProcessTitle , " --group= $ groupId " ) !== false ) {
962
+ // Group is already shown, so no need to include here in duplicate
963
+ cli_set_process_title ($ this ->originalProcessTitle . " # job: $ jobCode " );
964
+ } else {
965
+ cli_set_process_title ($ this ->originalProcessTitle . " # group: $ groupId, job: $ jobCode " );
966
+ }
967
+ }
957
968
}
0 commit comments