@@ -12,9 +12,9 @@ |
||
| 12 | 12 | namespace DNXLabs\LaravelQueueAwsBatch\Connectors; |
| 13 | 13 | |
| 14 | 14 | use Aws\Batch\BatchClient; |
| 15 | +use DNXLabs\LaravelQueueAwsBatch\Queues\BatchQueue; |
|
| 15 | 16 | use Illuminate\Queue\Connectors\DatabaseConnector; |
| 16 | 17 | use Illuminate\Support\Arr; |
| 17 | -use DNXLabs\LaravelQueueAwsBatch\Queues\BatchQueue; |
|
| 18 | 18 | |
| 19 | 19 | class BatchConnector extends DatabaseConnector |
| 20 | 20 | { |
@@ -11,6 +11,9 @@ discard block |
||
| 11 | 11 | |
| 12 | 12 | namespace DNXLabs\LaravelQueueAwsBatch\Console; |
| 13 | 13 | |
| 14 | +use DNXLabs\LaravelQueueAwsBatch\Exceptions\JobNotFoundException; |
|
| 15 | +use DNXLabs\LaravelQueueAwsBatch\Exceptions\UnsupportedException; |
|
| 16 | +use DNXLabs\LaravelQueueAwsBatch\Queues\BatchQueue; |
|
| 14 | 17 | use Illuminate\Container\Container; |
| 15 | 18 | use Illuminate\Contracts\Cache\Repository; |
| 16 | 19 | use Illuminate\Foundation\Exceptions\Handler; |
@@ -18,9 +21,6 @@ discard block |
||
| 18 | 21 | use Illuminate\Queue\QueueManager; |
| 19 | 22 | use Illuminate\Queue\Worker; |
| 20 | 23 | use Illuminate\Queue\WorkerOptions; |
| 21 | -use DNXLabs\LaravelQueueAwsBatch\Exceptions\JobNotFoundException; |
|
| 22 | -use DNXLabs\LaravelQueueAwsBatch\Exceptions\UnsupportedException; |
|
| 23 | -use DNXLabs\LaravelQueueAwsBatch\Queues\BatchQueue; |
|
| 24 | 24 | use Symfony\Component\Debug\Exception\FatalThrowableError; |
| 25 | 25 | |
| 26 | 26 | class QueueWorkBatchCommand extends WorkCommand |
@@ -115,6 +115,9 @@ |
||
| 115 | 115 | return $this->marshalJob($job->queue, $job); |
| 116 | 116 | } |
| 117 | 117 | |
| 118 | + /** |
|
| 119 | + * @param DatabaseJobRecord $job |
|
| 120 | + */ |
|
| 118 | 121 | protected function marshalJob($queue, $job) |
| 119 | 122 | { |
| 120 | 123 | $job = $this->markJobAsReserved($job); |
@@ -12,12 +12,12 @@ |
||
| 12 | 12 | namespace DNXLabs\LaravelQueueAwsBatch\Queues; |
| 13 | 13 | |
| 14 | 14 | use Aws\Batch\BatchClient; |
| 15 | -use Illuminate\Database\Connection; |
|
| 16 | -use Illuminate\Queue\DatabaseQueue; |
|
| 17 | -use Illuminate\Queue\Jobs\DatabaseJobRecord; |
|
| 18 | 15 | use DNXLabs\LaravelQueueAwsBatch\Exceptions\JobNotFoundException; |
| 19 | 16 | use DNXLabs\LaravelQueueAwsBatch\Exceptions\UnsupportedException; |
| 20 | 17 | use DNXLabs\LaravelQueueAwsBatch\Jobs\BatchJob; |
| 18 | +use Illuminate\Database\Connection; |
|
| 19 | +use Illuminate\Queue\DatabaseQueue; |
|
| 20 | +use Illuminate\Queue\Jobs\DatabaseJobRecord; |
|
| 21 | 21 | |
| 22 | 22 | class BatchQueue extends DatabaseQueue |
| 23 | 23 | { |