Queue::fake the seven V2 timer-wait cancel/terminate tests + respect available_at in drainReadyTasks

Same bucket A root cause as the signal-command fix: cancel/terminate
tests that wait for a workflow to park on a timer were racing the
real testbench queue workers. Under CI load the first waitFor could
outrun the worker even with the 30s budget.

Converting to Queue::fake + drainReadyTasks wasn't enough on its own
because drainReadyTasks in V2WorkflowTest didn't consult `available_at`
— a timer task scheduled for +2s was created with status=Ready, so
the drain loop fired the timer immediately and the workflow completed
before the test could cancel. Fix the drain filter so it matches the
real worker's semantics: only run tasks whose `available_at` is null
or already in the past.

With the drain respecting `available_at`, these seven tests can now
use the same Queue::fake + drainReadyTasks pattern as every other
reliable test in the file:

  * testWorkflowCanBeCancelledWhileWaitingOnTimer
  * testWorkflowCanBeTerminatedWhileWaitingOnTimer
  * testCancelWithoutReasonLeavesReasonNull
  * testCancelCreatesFailureRowWithCancelledCategory
  * testTerminateCreatesFailureRowWithTerminatedCategory
  * testCancelWithoutReasonCreatesFailureRowWithDefaultMessage
  * testCancelFailureRowAppearsInFailureSnapshots

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: durable-workflow-ops

tests/Feature/V2/V2WorkflowTest.php

@@ -6561,13 +6561,17 @@ public function testWorkflowCanCompleteImmediateTimerWithoutSchedulingATimerTask
 
     public function testWorkflowCanBeCancelledWhileWaitingOnTimer(): void
     {
+        Queue::fake();
+
         $workflow = WorkflowStub::make(TestTimerWorkflow::class);
         $workflow->start(2);
 
         $runId = $workflow->runId();
 
         $this->assertNotNull($runId);
 
+        $this->drainReadyTasks();
+
         $this->waitFor(static fn (): bool => $workflow->refresh()->status() === 'waiting'
             && $workflow->summary()?->wait_kind === 'timer');
 
@@ -6680,13 +6684,17 @@ public function testRunTargetedCancelUsesRunScopeForCurrentRun(): void
 
     public function testWorkflowCanBeTerminatedWhileWaitingOnTimer(): void
     {
+        Queue::fake();
+
         $workflow = WorkflowStub::make(TestTimerWorkflow::class);
         $workflow->start(5);
 
         $runId = $workflow->runId();
 
         $this->assertNotNull($runId);
 
+        $this->drainReadyTasks();
+
         $this->waitFor(static fn (): bool => $workflow->refresh()->status() === 'waiting'
             && $workflow->summary()?->wait_kind === 'timer');
 
@@ -7803,13 +7811,17 @@ public function testWorkflowCanBeTerminatedWithReasonWhileWaitingOnActivity(): v
 
     public function testCancelWithoutReasonLeavesReasonNull(): void
     {
+        Queue::fake();
+
         $workflow = WorkflowStub::make(TestTimerWorkflow::class, 'cancel-no-reason');
         $workflow->start(2);
 
         $runId = $workflow->runId();
 
         $this->assertNotNull($runId);
 
+        $this->drainReadyTasks();
+
         $this->waitFor(static fn (): bool => $workflow->refresh()->status() === 'waiting'
             && $workflow->summary()?->wait_kind === 'timer');
 
@@ -7833,13 +7845,17 @@ public function testCancelWithoutReasonLeavesReasonNull(): void
 
     public function testCancelCreatesFailureRowWithCancelledCategory(): void
     {
+        Queue::fake();
+
         $workflow = WorkflowStub::make(TestTimerWorkflow::class, 'cancel-failure-row');
         $workflow->start(5);
 
         $runId = $workflow->runId();
 
         $this->assertNotNull($runId);
 
+        $this->drainReadyTasks();
+
         $this->waitFor(static fn (): bool => $workflow->refresh()->status() === 'waiting'
             && $workflow->summary()?->wait_kind === 'timer');
 
@@ -7883,13 +7899,17 @@ public function testCancelCreatesFailureRowWithCancelledCategory(): void
 
     public function testTerminateCreatesFailureRowWithTerminatedCategory(): void
     {
+        Queue::fake();
+
         $workflow = WorkflowStub::make(TestTimerWorkflow::class, 'terminate-failure-row');
         $workflow->start(5);
 
         $runId = $workflow->runId();
 
         $this->assertNotNull($runId);
 
+        $this->drainReadyTasks();
+
         $this->waitFor(static fn (): bool => $workflow->refresh()->status() === 'waiting'
             && $workflow->summary()?->wait_kind === 'timer');
 
@@ -7933,13 +7953,17 @@ public function testTerminateCreatesFailureRowWithTerminatedCategory(): void
 
     public function testCancelWithoutReasonCreatesFailureRowWithDefaultMessage(): void
     {
+        Queue::fake();
+
         $workflow = WorkflowStub::make(TestTimerWorkflow::class, 'cancel-no-reason-failure');
         $workflow->start(5);
 
         $runId = $workflow->runId();
 
         $this->assertNotNull($runId);
 
+        $this->drainReadyTasks();
+
         $this->waitFor(static fn (): bool => $workflow->refresh()->status() === 'waiting'
             && $workflow->summary()?->wait_kind === 'timer');
 
@@ -7957,13 +7981,17 @@ public function testCancelWithoutReasonCreatesFailureRowWithDefaultMessage(): vo
 
     public function testCancelFailureRowAppearsInFailureSnapshots(): void
     {
+        Queue::fake();
+
         $workflow = WorkflowStub::make(TestTimerWorkflow::class, 'cancel-snapshots');
         $workflow->start(5);
 
         $runId = $workflow->runId();
 
         $this->assertNotNull($runId);
 
+        $this->drainReadyTasks();
+
         $this->waitFor(static fn (): bool => $workflow->refresh()->status() === 'waiting'
             && $workflow->summary()?->wait_kind === 'timer');
 
@@ -8014,6 +8042,10 @@ private function drainReadyTasks(): void
             /** @var WorkflowTask|null $task */
             $task = WorkflowTask::query()
                 ->where('status', TaskStatus::Ready->value)
+                ->where(static function ($query): void {
+                    $query->whereNull('available_at')
+                        ->orWhere('available_at', '<=', now());
+                })
                 ->orderBy('created_at')
                 ->first();