Import Deferred in probe code

Author: durable-workflow-ops

src/Traits/SideEffects.php

@@ -5,6 +5,7 @@
 namespace Workflow\Traits;
 
 use Illuminate\Database\QueryException;
+use React\Promise\Deferred;
 use React\Promise\PromiseInterface;
 use function React\Promise\resolve;
 use Workflow\Serializers\Serializer;
@@ -22,7 +23,7 @@ public static function sideEffect($callable): PromiseInterface
 
         if (self::isProbing()) {
             ++self::$context->index;
-            return (new \React\Promise\Deferred())->promise();
+            return (new Deferred())->promise();
         }
 
         $result = $callable();

src/Traits/Versions.php

@@ -5,6 +5,7 @@
 namespace Workflow\Traits;
 
 use Illuminate\Database\QueryException;
+use React\Promise\Deferred;
 use React\Promise\PromiseInterface;
 use function React\Promise\resolve;
 use Workflow\Exceptions\VersionNotSupportedException;
@@ -35,7 +36,7 @@ public static function getVersion(
 
         if (self::isProbing()) {
             ++self::$context->index;
-            return (new \React\Promise\Deferred())->promise();
+            return (new Deferred())->promise();
         }
 
         $version = $maxSupported;

tests/Unit/ExceptionTest.php

@@ -4,6 +4,9 @@
 
 namespace Tests\Unit;
 
+use Exception as BaseException;
+use InvalidArgumentException;
+use RuntimeException;
 use Tests\Fixtures\TestProbeBackToBackWorkflow;
 use Tests\Fixtures\TestProbeChildFailureWorkflow;
 use Tests\Fixtures\TestProbeParallelChildWorkflow;
@@ -21,7 +24,7 @@ final class ExceptionTest extends TestCase
 {
     public function testMiddleware(): void
     {
-        $exception = new Exception(0, now()->toDateTimeString(), new StoredWorkflow(), new \Exception(
+        $exception = new Exception(0, now()->toDateTimeString(), new StoredWorkflow(), new BaseException(
             'Test exception'
         ));
 
@@ -42,7 +45,7 @@ public function testExceptionWorkflowRunning(): void
             'status' => WorkflowRunningStatus::$name,
         ]);
 
-        $exception = new Exception(0, now()->toDateTimeString(), $storedWorkflow, new \Exception('Test exception'));
+        $exception = new Exception(0, now()->toDateTimeString(), $storedWorkflow, new BaseException('Test exception'));
         $exception->handle();
 
         $this->assertSame(WorkflowRunningStatus::class, $workflow->status());
@@ -64,14 +67,14 @@ public function testSkipsWriteWhenProbeDoesNotReachCandidateException(): void
                     ->toDateTimeString(),
                 'class' => Exception::class,
                 'result' => Serializer::serialize([
-                    'class' => \Exception::class,
+                    'class' => BaseException::class,
                     'message' => 'child failed: child-1',
                     'code' => 0,
                 ]),
             ]);
 
         $exception = new Exception(1, now()->toDateTimeString(), $storedWorkflow, [
-            'class' => \Exception::class,
+            'class' => BaseException::class,
             'message' => 'child failed: child-2',
             'code' => 0,
         ], sourceClass: TestProbeChildFailureWorkflow::class);
@@ -97,14 +100,14 @@ public function testPersistsWriteWhenProbeReachesCandidateException(): void
                     ->toDateTimeString(),
                 'class' => Exception::class,
                 'result' => Serializer::serialize([
-                    'class' => \RuntimeException::class,
+                    'class' => RuntimeException::class,
                     'message' => 'first failure',
                     'code' => 0,
                 ]),
             ]);
 
         $exception = new Exception(1, now()->toDateTimeString(), $storedWorkflow, [
-            'class' => \InvalidArgumentException::class,
+            'class' => InvalidArgumentException::class,
             'message' => 'second failure',
             'code' => 0,
         ], sourceClass: TestProbeRetryActivity::class);