Skip to content

Commit 4ccf9bc

Browse files
committed
Add self healing.
1 parent 28f565e commit 4ccf9bc

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/Shell/QueueShell.php

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -166,6 +166,9 @@ public function runworker() {
166166
if ($limit) {
167167
$this->out('Cannot start worker: Too many workers already/still running on this server (' . $limit . '/' . $limit . ')');
168168
}
169+
170+
$this->QueueProcesses->cleanEndedProcesses();
171+
169172
return static::CODE_ERROR;
170173
}
171174

0 commit comments

Comments
 (0)