Respect "don't fork"
This commit is contained in:
parent
3034170088
commit
371f511954
1 changed files with 5 additions and 5 deletions
|
@ -1084,14 +1084,14 @@ class Worker
|
||||||
dba::insert('workerqueue', ['parameter' => $parameters, 'created' => $created, 'priority' => $priority]);
|
dba::insert('workerqueue', ['parameter' => $parameters, 'created' => $created, 'priority' => $priority]);
|
||||||
}
|
}
|
||||||
|
|
||||||
// We tell the daemon that a new job entry exists
|
// Should we quit and wait for the worker to be called as a cronjob?
|
||||||
if (Config::get('system', 'worker_daemon_mode', false)) {
|
if ($dont_fork) {
|
||||||
self::IPCSetJobState(true);
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Should we quit and wait for the worker to be called as a cronjob?
|
// We tell the daemon that a new job entry exists
|
||||||
if ($dont_fork) {
|
if (Config::get('system', 'worker_daemon_mode', false)) {
|
||||||
|
self::IPCSetJobState(true);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue