mmucklo /
DtcQueueBundle
| @@ 1113-1134 (lines=22) @@ | ||
| 1110 | parent::testPerformance(); |
|
| 1111 | } |
|
| 1112 | ||
| 1113 | protected function getBaseStatus() |
|
| 1114 | { |
|
| 1115 | /** @var JobManager|\Dtc\QueueBundle\ORM\JobManager $jobManager */ |
|
| 1116 | $jobManager = self::$jobManager; |
|
| 1117 | $job = new self::$jobClass(self::$worker, false, null); |
|
| 1118 | $job->fibonacci(1); |
|
| 1119 | $status = $jobManager->getStatus(); |
|
| 1120 | self::assertArrayHasKey('fibonacci->fibonacci()', $status); |
|
| 1121 | $fibonacciStatus = $status['fibonacci->fibonacci()']; |
|
| 1122 | ||
| 1123 | self::assertArrayHasKey(BaseJob::STATUS_NEW, $fibonacciStatus); |
|
| 1124 | self::assertArrayHasKey(BaseJob::STATUS_EXCEPTION, $fibonacciStatus); |
|
| 1125 | self::assertArrayHasKey(BaseJob::STATUS_RUNNING, $fibonacciStatus); |
|
| 1126 | self::assertArrayHasKey(BaseJob::STATUS_SUCCESS, $fibonacciStatus); |
|
| 1127 | self::assertArrayHasKey(Job::STATUS_EXPIRED, $fibonacciStatus); |
|
| 1128 | self::assertArrayHasKey(StallableJob::STATUS_MAX_STALLS, $fibonacciStatus); |
|
| 1129 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_EXCEPTIONS, $fibonacciStatus); |
|
| 1130 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_FAILURES, $fibonacciStatus); |
|
| 1131 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_RETRIES, $fibonacciStatus); |
|
| 1132 | ||
| 1133 | return [$job, $status]; |
|
| 1134 | } |
|
| 1135 | ||
| 1136 | public function testGetStatus() |
|
| 1137 | { |
|
| @@ 260-280 (lines=21) @@ | ||
| 257 | self::assertEquals($fibonacciStatus1[BaseJob::STATUS_NEW] + 1, $fibonacciStatus2[BaseJob::STATUS_NEW]); |
|
| 258 | } |
|
| 259 | ||
| 260 | protected function getBaseStatus() |
|
| 261 | { |
|
| 262 | /** @var JobManager|\Dtc\QueueBundle\ORM\JobManager $jobManager */ |
|
| 263 | $jobManager = self::$jobManager; |
|
| 264 | $job = new self::$jobClass(self::$worker, false, null); |
|
| 265 | $job->fibonacci(1); |
|
| 266 | $status = $jobManager->getStatus(); |
|
| 267 | self::assertArrayHasKey('fibonacci->fibonacci()', $status); |
|
| 268 | $fibonacciStatus = $status['fibonacci->fibonacci()']; |
|
| 269 | ||
| 270 | self::assertArrayHasKey(BaseJob::STATUS_NEW, $fibonacciStatus); |
|
| 271 | self::assertArrayHasKey(BaseJob::STATUS_EXCEPTION, $fibonacciStatus); |
|
| 272 | self::assertArrayHasKey(BaseJob::STATUS_RUNNING, $fibonacciStatus); |
|
| 273 | self::assertArrayHasKey(BaseJob::STATUS_SUCCESS, $fibonacciStatus); |
|
| 274 | self::assertArrayHasKey(Job::STATUS_EXPIRED, $fibonacciStatus); |
|
| 275 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_EXCEPTIONS, $fibonacciStatus); |
|
| 276 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_FAILURES, $fibonacciStatus); |
|
| 277 | self::assertArrayHasKey(RetryableJob::STATUS_MAX_RETRIES, $fibonacciStatus); |
|
| 278 | ||
| 279 | return [$job, $status]; |
|
| 280 | } |
|
| 281 | } |
|
| 282 | ||
