Skip to content

Commit 5907258

Browse files
committed
Include progress field in _findProgress() method
1 parent d416ac9 commit 5907258

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

Model/QueuedTask.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -355,6 +355,7 @@ protected function _findProgress($state, $query = [], $results = []) {
355355
$query['fields'] = [
356356
$this->alias . '.reference',
357357
'(CASE WHEN ' . $this->alias . '.notbefore > NOW() THEN \'NOT_READY\' WHEN ' . $this->alias . '.fetched IS null THEN \'NOT_STARTED\' WHEN ' . $this->alias . '.fetched IS NOT null AND ' . $this->alias . '.completed IS null AND ' . $this->alias . '.failed = 0 THEN \'IN_PROGRESS\' WHEN ' . $this->alias . '.fetched IS NOT null AND ' . $this->alias . '.completed IS null AND ' . $this->alias . '.failed > 0 THEN \'FAILED\' WHEN ' . $this->alias . '.fetched IS NOT null AND ' . $this->alias . '.completed IS NOT null THEN \'COMPLETED\' ELSE \'UNKNOWN\' END) AS status',
358+
$this->alias . '.progress',
358359
$this->alias . '.failure_message'
359360
];
360361
if (isset($query['conditions']['exclude'])) {
@@ -380,6 +381,9 @@ protected function _findProgress($state, $query = [], $results = []) {
380381
'reference' => $result[$this->alias]['reference'],
381382
'status' => $result[0]['status']
382383
];
384+
if (!empty($result[$this->alias]['progress'])) {
385+
$results[$k]['progress'] = $result[$this->alias]['progress'];
386+
}
383387
if (!empty($result[$this->alias]['failure_message'])) {
384388
$results[$k]['failure_message'] = $result[$this->alias]['failure_message'];
385389
}

0 commit comments

Comments
 (0)