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 | { |
|
| @@ 283-303 (lines=21) @@ | ||
| 280 | self::assertEquals($fibonacciStatus1[BaseJob::STATUS_NEW] + 1, $fibonacciStatus2[BaseJob::STATUS_NEW]); |
|
| 281 | } |
|
| 282 | ||
| 283 | protected function getBaseStatus() |
|
| 284 | { |
|
| 285 | /** @var JobManager|\Dtc\QueueBundle\ORM\JobManager $jobManager */ |
|
| 286 | $jobManager = self::$jobManager; |
|
| 287 | $job = new self::$jobClass(self::$worker, false, null); |
|
| 288 | $job->fibonacci(1); |
|
| 289 | $status = $jobManager->getStatus(); |
|
| 290 | self::assertArrayHasKey('fibonacci->fibonacci()', $status); |
|
| 291 | $fibonacciStatus = $status['fibonacci->fibonacci()']; |
|
| 292 | ||
| 293 | self::assertArrayHasKey(BaseJob::STATUS_NEW, $fibonacciStatus); |
|
| 294 | self::assertArrayHasKey(BaseJob::STATUS_EXCEPTION, $fibonacciStatus); |
|
| 295 | self::assertArrayHasKey(BaseJob::STATUS_RUNNING, $fibonacciStatus); |
|
| 296 | self::assertArrayHasKey(BaseJob::STATUS_SUCCESS, $fibonacciStatus); |
|
| 297 | self::assertArrayHasKey(Job::STATUS_EXPIRED, $fibonacciStatus); |
|
| 298 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_EXCEPTIONS, $fibonacciStatus); |
|
| 299 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_FAILURES, $fibonacciStatus); |
|
| 300 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_RETRIES, $fibonacciStatus); |
|
| 301 | ||
| 302 | return [$job, $status]; |
|
| 303 | } |
|
| 304 | } |
|
| 305 | ||
