[5.x] Add ability to specify the queue connection on static:warm command

config/static_caching.php

@@ -125,4 +125,16 @@
 
     'warm_queue' => null,
 
+    /*
+    |--------------------------------------------------------------------------
+    | Queue Connection
+    |--------------------------------------------------------------------------
+    |
+    | Here you may define the queue connection name that
+    | will be used when warming the static cache.
+    |
+    */
+
+    'queue_connection' => env('STATAMIC_STATIC_WARM_QUEUE_CONNECTION'),
+
 ];

src/Console/Commands/StaticWarm.php

@@ -29,7 +29,8 @@ class StaticWarm extends Command
     use RunsInPlease;
 
     protected $signature = 'statamic:static:warm
-        {--queue : Queue the requests}
+        {--queue= : Queue the requests}
+        {--connection= : Specify the connection name for the queue, i.e. redis }
         {--u|user= : HTTP authentication user}
         {--p|password= : HTTP authentication password}
         {--insecure : Skip SSL verification}
@@ -38,6 +39,7 @@ class StaticWarm extends Command
     protected $description = 'Warms the static cache by visiting all URLs';
 
     protected $shouldQueue = false;
+    protected $queueConnection;
 
     private $uris;
 
@@ -49,9 +51,11 @@ public function handle()
             return 1;
         }
 
-        $this->shouldQueue = $this->option('queue');
+        $this->shouldQueue = (bool) $this->option('queue');
+        $this->queueConnection = $this->option('connection') ??
+            (config('statamic.static_caching.queue_connection') ?? config('queue.default'));
 
-        if ($this->shouldQueue && config('queue.default') === 'sync') {
+        if ($this->shouldQueue && $this->queueConnection === 'sync') {
             $this->error('The queue connection is set to "sync". Queueing will be disabled.');
             $this->shouldQueue = false;
         }
@@ -90,7 +94,9 @@ private function warm(): void
             $this->line(sprintf('Adding %s requests onto %squeue...', count($requests), $queue ? $queue.' ' : ''));
 
             foreach ($requests as $request) {
-                StaticWarmJob::dispatch($request)->onQueue($queue);
+                StaticWarmJob::dispatch($request)
+                    ->onConnection($this->queueConnection)
+                    ->onQueue($queue);
             }
         } else {
             $this->line('Visiting '.count($requests).' URLs...');

tests/Console/Commands/StaticWarmTest.php

@@ -17,10 +17,6 @@ public function setUp(): void
     {
         parent::setUp();
 
-        // Temporarily skip because we get random failures.
-        // If you spam it_warms_the_static_cache, it'll eventually fail.
-        $this->markTestIncomplete();
-
         $this->createPage('about');
         $this->createPage('contact');
     }
@@ -53,6 +49,45 @@ public function it_doesnt_queue_the_requests_when_connection_is_set_to_sync()
             ->assertExitCode(0);
     }
 
+    /** @test */
+    public function it_queues_the_requests_with_connection_option()
+    {
+        config([
+            'statamic.static_caching.strategy' => 'half',
+            'queue.default' => 'sync',
+        ]);
+
+        Queue::fake();
+
+        $this->artisan('statamic:static:warm', ['--queue' => true, '--connection' => 'redis'])
+            ->expectsOutputToContain('Adding 2 requests')
+            ->assertExitCode(0);
+
+        Queue::assertPushed(StaticWarmJob::class, function ($job) {
+            return $job->connection === 'redis';
+        });
+    }
+
+    /** @test */
+    public function it_queues_the_requests_with_connection_config()
+    {
+        config([
+            'statamic.static_caching.strategy' => 'half',
+            'statamic.static_caching.queue_connection' => 'redis',
+            'queue.default' => 'sync',
+        ]);
+
+        Queue::fake();
+
+        $this->artisan('statamic:static:warm', ['--queue' => true])
+            ->expectsOutputToContain('Adding 2 requests')
+            ->assertExitCode(0);
+
+        Queue::assertPushed(StaticWarmJob::class, function ($job) {
+            return $job->connection === 'redis';
+        });
+    }
+
     /** @test */
     public function it_queues_the_requests()
     {
@@ -64,7 +99,7 @@ public function it_queues_the_requests()
         Queue::fake();
 
         $this->artisan('statamic:static:warm', ['--queue' => true])
-            ->expectsOutput('Queueing 2 requests...')
+            ->expectsOutputToContain('Adding 2 requests')
             ->assertExitCode(0);
 
         Queue::assertPushed(StaticWarmJob::class, function ($job) {