Normalize probe replay now context

Author: durable-workflow-ops

src/Exception.php

@@ -10,6 +10,7 @@
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Carbon;
 use Illuminate\Support\Facades\Cache;
 use ReflectionClass;
 use Throwable;
@@ -138,7 +139,7 @@ private function probeReplayDecision(): string
             WorkflowStub::setContext([
                 'storedWorkflow' => $tentativeWorkflow,
                 'index' => 0,
-                'now' => $this->now,
+                'now' => Carbon::parse($this->now),
                 'replaying' => true,
                 'probing' => true,
                 'probeIndex' => $this->index,

tests/Fixtures/TestProbeNowSignalWorkflow.php

@@ -0,0 +1,30 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Tests\Fixtures;
+
+use Illuminate\Support\Carbon;
+use Workflow\SignalMethod;
+use Workflow\Workflow;
+use Workflow\WorkflowStub;
+
+final class TestProbeNowSignalWorkflow extends Workflow
+{
+    public static bool $signalSawCarbonNow = false;
+
+    #[SignalMethod]
+    public function recordNowType(): void
+    {
+        self::$signalSawCarbonNow = WorkflowStub::now() instanceof Carbon;
+    }
+
+    public function execute()
+    {
+        if (false) {
+            yield;
+        }
+
+        return 'ok';
+    }
+}

tests/Unit/ExceptionTest.php

@@ -15,6 +15,7 @@
 use Tests\Fixtures\TestActivity;
 use Tests\Fixtures\TestProbeBackToBackWorkflow;
 use Tests\Fixtures\TestProbeChildFailureWorkflow;
+use Tests\Fixtures\TestProbeNowSignalWorkflow;
 use Tests\Fixtures\TestProbeParallelChildWorkflow;
 use Tests\Fixtures\TestProbeRetryActivity;
 use Tests\Fixtures\TestSagaActivity;
@@ -237,6 +238,35 @@ public function testProbeReplayShortCircuitsWhenWorkflowClassAutoloadThrows(): v
         }
     }
 
+    public function testProbeReplayUsesCarbonNowBeforeWorkflowHandleResetsContext(): void
+    {
+        TestProbeNowSignalWorkflow::$signalSawCarbonNow = false;
+
+        $workflow = WorkflowStub::load(WorkflowStub::make(TestProbeNowSignalWorkflow::class)->id());
+        $storedWorkflow = StoredWorkflow::findOrFail($workflow->id());
+        $storedWorkflow->update([
+            'arguments' => Serializer::serialize([]),
+            'status' => WorkflowRunningStatus::$name,
+        ]);
+        $storedWorkflow->signals()
+            ->create([
+                'method' => 'recordNowType',
+                'arguments' => Serializer::serialize([]),
+            ]);
+
+        $exception = new Exception(0, now()->toDateTimeString(), $storedWorkflow, [
+            'class' => BaseException::class,
+            'message' => 'probe now type',
+            'code' => 0,
+        ], connection: 'redis', queue: 'default');
+
+        $method = new ReflectionMethod(Exception::class, 'probeReplayDecision');
+        $method->setAccessible(true);
+        $method->invoke($exception);
+
+        $this->assertTrue(TestProbeNowSignalWorkflow::$signalSawCarbonNow);
+    }
+
     public function testSkipsWriteWhenProbeDoesNotReachCandidateException(): void
     {
         $workflow = WorkflowStub::load(WorkflowStub::make(TestProbeParallelChildWorkflow::class)->id());