mmucklo /
DtcQueueBundle
| @@ 1102-1123 (lines=22) @@ | ||
| 1099 | parent::testPerformance(); |
|
| 1100 | } |
|
| 1101 | ||
| 1102 | protected function getBaseStatus() |
|
| 1103 | { |
|
| 1104 | /** @var JobManager|\Dtc\QueueBundle\ORM\JobManager $jobManager */ |
|
| 1105 | $jobManager = self::$jobManager; |
|
| 1106 | $job = new self::$jobClass(self::$worker, false, null); |
|
| 1107 | $job->fibonacci(1); |
|
| 1108 | $status = $jobManager->getStatus(); |
|
| 1109 | self::assertArrayHasKey('fibonacci->fibonacci()', $status); |
|
| 1110 | $fibonacciStatus = $status['fibonacci->fibonacci()']; |
|
| 1111 | ||
| 1112 | self::assertArrayHasKey(BaseJob::STATUS_NEW, $fibonacciStatus); |
|
| 1113 | self::assertArrayHasKey(BaseJob::STATUS_EXCEPTION, $fibonacciStatus); |
|
| 1114 | self::assertArrayHasKey(BaseJob::STATUS_RUNNING, $fibonacciStatus); |
|
| 1115 | self::assertArrayHasKey(BaseJob::STATUS_SUCCESS, $fibonacciStatus); |
|
| 1116 | self::assertArrayHasKey(Job::STATUS_EXPIRED, $fibonacciStatus); |
|
| 1117 | self::assertArrayHasKey(StallableJob::STATUS_MAX_STALLS, $fibonacciStatus); |
|
| 1118 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_EXCEPTIONS, $fibonacciStatus); |
|
| 1119 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_FAILURES, $fibonacciStatus); |
|
| 1120 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_RETRIES, $fibonacciStatus); |
|
| 1121 | ||
| 1122 | return [$job, $status]; |
|
| 1123 | } |
|
| 1124 | ||
| 1125 | public function testGetStatus() |
|
| 1126 | { |
|
| @@ 210-230 (lines=21) @@ | ||
| 207 | self::assertEquals($fibonacciStatus1[BaseJob::STATUS_NEW] + 1, $fibonacciStatus2[BaseJob::STATUS_NEW]); |
|
| 208 | } |
|
| 209 | ||
| 210 | protected function getBaseStatus() |
|
| 211 | { |
|
| 212 | /** @var JobManager|\Dtc\QueueBundle\ORM\JobManager $jobManager */ |
|
| 213 | $jobManager = self::$jobManager; |
|
| 214 | $job = new self::$jobClass(self::$worker, false, null); |
|
| 215 | $job->fibonacci(1); |
|
| 216 | $status = $jobManager->getStatus(); |
|
| 217 | self::assertArrayHasKey('fibonacci->fibonacci()', $status); |
|
| 218 | $fibonacciStatus = $status['fibonacci->fibonacci()']; |
|
| 219 | ||
| 220 | self::assertArrayHasKey(BaseJob::STATUS_NEW, $fibonacciStatus); |
|
| 221 | self::assertArrayHasKey(BaseJob::STATUS_EXCEPTION, $fibonacciStatus); |
|
| 222 | self::assertArrayHasKey(BaseJob::STATUS_RUNNING, $fibonacciStatus); |
|
| 223 | self::assertArrayHasKey(BaseJob::STATUS_SUCCESS, $fibonacciStatus); |
|
| 224 | self::assertArrayHasKey(Job::STATUS_EXPIRED, $fibonacciStatus); |
|
| 225 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_EXCEPTIONS, $fibonacciStatus); |
|
| 226 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_FAILURES, $fibonacciStatus); |
|
| 227 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_RETRIES, $fibonacciStatus); |
|
| 228 | ||
| 229 | return [$job, $status]; |
|
| 230 | } |
|
| 231 | } |
|
| 232 | ||
