|
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