|  | 
| 17 | 17 |             )->queuesToConsume->toBe(['default'] | 
| 18 | 18 |             ); | 
| 19 | 19 | 
 | 
| 20 |  | -            expect(Arr::first(array_filter($configObject, fn (QueueConfig $config) => $config->alias === $worker)))->memoryLimit->toBe(128); | 
| 21 |  | -            expect(Arr::first(array_filter($configObject, fn (QueueConfig $config) => $config->alias === $worker)))->timeout->toBe(60); | 
|  | 20 | +            expect(Arr::first(array_filter($configObject, | 
|  | 21 | +                fn (QueueConfig $config) => $config->alias === $worker)))->memoryLimit->toBe(128); | 
|  | 22 | +            expect(Arr::first(array_filter($configObject, | 
|  | 23 | +                fn (QueueConfig $config) => $config->alias === $worker)))->timeout->toBe(60); | 
| 22 | 24 | 
 | 
| 23 | 25 |             continue; | 
| 24 | 26 |         } | 
|  | 
| 29 | 31 |         )->queuesToConsume->toBe($worker['queues'] ?? ['default'] | 
| 30 | 32 |         ); | 
| 31 | 33 | 
 | 
| 32 |  | -        expect(Arr::first(array_filter($configObject, fn (QueueConfig $config) => $config->alias === $alias)))->memoryLimit->toBe($worker['memory_limit'] ?? 128); | 
| 33 |  | -        expect(Arr::first(array_filter($configObject, fn (QueueConfig $config) => $config->alias === $alias)))->timeout->toBe($worker['timeout'] ?? 60); | 
|  | 34 | +        expect(Arr::first(array_filter($configObject, | 
|  | 35 | +            fn (QueueConfig $config) => $config->alias === $alias)))->memoryLimit->toBe($worker['memory_limit'] ?? 128); | 
|  | 36 | +        expect(Arr::first(array_filter($configObject, | 
|  | 37 | +            fn (QueueConfig $config) => $config->alias === $alias)))->timeout->toBe($worker['timeout'] ?? 60); | 
| 34 | 38 |     } | 
| 35 | 39 | })->with([ | 
| 36 | 40 |     [ | 
| 37 |  | -        'queue_workers' => [ | 
| 38 |  | -            'some_worker' => [ | 
| 39 |  | -                'queues' => ['default'], | 
| 40 |  | -                'memory_limit' => 64, | 
| 41 |  | -                'timeout' => 60, | 
|  | 41 | +        [ | 
|  | 42 | +            'queue_workers' => [ | 
|  | 43 | +                'some_worker' => [ | 
|  | 44 | +                    'queues' => ['default'], | 
|  | 45 | +                    'memory_limit' => 64, | 
|  | 46 | +                    'timeout' => 60, | 
|  | 47 | +                ], | 
| 42 | 48 |             ], | 
| 43 | 49 |         ], | 
| 44 | 50 |     ], | 
| 45 | 51 |     [ | 
| 46 |  | -        'queue_workers' => [ | 
| 47 |  | -            'some_worker' => [], | 
| 48 |  | -            'another_worker' => [], | 
|  | 52 | +        [ | 
|  | 53 | +            'queue_workers' => [ | 
|  | 54 | +                'some_worker' => [], | 
|  | 55 | +                'another_worker' => [], | 
|  | 56 | +            ], | 
| 49 | 57 |         ], | 
| 50 | 58 |     ], | 
| 51 | 59 |     [ | 
| 52 |  | -        'queue_workers' => [ | 
| 53 |  | -            'some_worker' => [ | 
| 54 |  | -            ], | 
| 55 |  | -            'another_worker' => [ | 
| 56 |  | -                'queues' => ['default', 'another'], | 
| 57 |  | -            ], | 
| 58 |  | -            'yet_another_worker' => [ | 
| 59 |  | -                'memory_limit' => 256, | 
| 60 |  | -            ], | 
| 61 |  | -            'one_more_worker' => [ | 
| 62 |  | -                'timeout' => 120, | 
|  | 60 | +        [ | 
|  | 61 | +            'queue_workers' => [ | 
|  | 62 | +                'some_worker' => [ | 
|  | 63 | +                ], | 
|  | 64 | +                'another_worker' => [ | 
|  | 65 | +                    'queues' => ['default', 'another'], | 
|  | 66 | +                ], | 
|  | 67 | +                'yet_another_worker' => [ | 
|  | 68 | +                    'memory_limit' => 256, | 
|  | 69 | +                ], | 
|  | 70 | +                'one_more_worker' => [ | 
|  | 71 | +                    'timeout' => 120, | 
|  | 72 | +                ], | 
| 63 | 73 |             ], | 
| 64 | 74 |         ], | 
| 65 | 75 |     ], | 
|  | 
0 commit comments