src/Comodojo/Extender/Jobs/Manager.php 1 location
|
@@ 102-124 (lines=23) @@
|
| 99 |
|
|
| 100 |
|
} |
| 101 |
|
|
| 102 |
|
public function isAborted($uid, $error) { |
| 103 |
|
|
| 104 |
|
$job = $this->running_jobs[$uid]; |
| 105 |
|
|
| 106 |
|
$this->logger->debug('Job '.$job->name.' (uid '.$job->uid.') aborted, reason: '.$error); |
| 107 |
|
|
| 108 |
|
$job->success = false; |
| 109 |
|
|
| 110 |
|
$job->result = $error; |
| 111 |
|
|
| 112 |
|
$job->wid = null; |
| 113 |
|
|
| 114 |
|
$job->end_timestamp = microtime(true); |
| 115 |
|
|
| 116 |
|
$this->completed_jobs[$uid] = $job; |
| 117 |
|
|
| 118 |
|
unset($this->queued_jobs[$uid]); |
| 119 |
|
|
| 120 |
|
$this->dump(); |
| 121 |
|
|
| 122 |
|
return $this; |
| 123 |
|
|
| 124 |
|
} |
| 125 |
|
|
| 126 |
|
public function queued() { |
| 127 |
|
|
src/Comodojo/Extender/Task/Locker.php 1 location
|
@@ 103-125 (lines=23) @@
|
| 100 |
|
|
| 101 |
|
} |
| 102 |
|
|
| 103 |
|
public function isAborted($uid, $error) { |
| 104 |
|
|
| 105 |
|
$job = $this->running_jobs[$uid]; |
| 106 |
|
|
| 107 |
|
$this->logger->debug('Job '.$job->name.' (uid '.$job->uid.') aborted, reason: '.$error); |
| 108 |
|
|
| 109 |
|
$job->success = false; |
| 110 |
|
|
| 111 |
|
$job->result = $error; |
| 112 |
|
|
| 113 |
|
$job->wid = null; |
| 114 |
|
|
| 115 |
|
$job->end_timestamp = microtime(true); |
| 116 |
|
|
| 117 |
|
$this->completed_jobs[$uid] = $job; |
| 118 |
|
|
| 119 |
|
unset($this->queued_jobs[$uid]); |
| 120 |
|
|
| 121 |
|
$this->dump(); |
| 122 |
|
|
| 123 |
|
return $this; |
| 124 |
|
|
| 125 |
|
} |
| 126 |
|
|
| 127 |
|
public function queued() { |
| 128 |
|
|