|
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