Expose retry policy in activity context (#656): Expose retry policy in activity context

Author: roxblnfk

composer.json

@@ -32,10 +32,10 @@
         "nesbot/carbon": "^2.72.6 || ^3.8.4",
         "psr/log": "^2.0 || ^3.0.2",
         "ramsey/uuid": "^4.7.6",
-        "roadrunner-php/roadrunner-api-dto": "^1.13.0",
-        "roadrunner-php/version-checker": "^1.0.1",
+        "roadrunner-php/roadrunner-api-dto": "^1.14.0",
+        "roadrunner-php/version-checker": "^1.0.2",
         "spiral/attributes": "^3.1.8",
-        "spiral/roadrunner": "^2025.1.3",
+        "spiral/roadrunner": "^2025.1.5",
         "spiral/roadrunner-cli": "^2.6",
         "spiral/roadrunner-kv": "^4.3.1",
         "spiral/roadrunner-worker": "^3.6.2",

dload.xml

@@ -4,7 +4,7 @@
        temp-dir="./runtime"
 >
     <actions>
-        <download software="rr" version="^2025.1.3"/>
+        <download software="rr" version="^2025.1.5"/>
         <download software="temporal" version="^1.4-fairness@dev"/>
         <download software="temporal-tests-server"/>
     </actions>

src/Activity/ActivityInfo.php

@@ -17,6 +17,7 @@
 use Temporal\Activity;
 use Temporal\Client\ActivityCompletionClientInterface;
 use Temporal\Common\Priority;
+use Temporal\Common\RetryOptions;
 use Temporal\Common\Uuid;
 use Temporal\Internal\Marshaller\Meta\Marshal;
 use Temporal\Internal\Marshaller\Type\DateIntervalType;
@@ -108,6 +109,9 @@ final class ActivityInfo
     #[Marshal(name: 'Priority')]
     public Priority $priority;
 
+    #[Marshal(name: 'RetryPolicy')]
+    public ?RetryOptions $retryOptions = null;
+
     /**
      * ActivityInfo constructor.
      */

tests/Acceptance/Extra/Activity/ActivityInfoTest.php

@@ -22,12 +22,10 @@ public static function retryPolicy(
         #[Stub('Extra_Activity_ActivityInfo', args: [TestWorkflow::ARG_RETRY_OPTIONS])]
         WorkflowStubInterface $stub,
     ): void {
-        self::markTestSkipped('See https://github.com/temporalio/sdk-php/issues/602');
-
         $result = $stub->getResult(type: 'array');
         self::assertSame([
             "initial_interval" => ['seconds' => 1, 'nanos' => 0],
-            "backoff_coefficient" => 3,
+            "backoff_coefficient" => 3.0,
             "maximum_interval" => ['seconds' => 120, 'nanos' => 0],
             "maximum_attempts" => 20,
             "non_retryable_error_types" => [],

tests/Unit/DTO/ActivityInfoTestCase.php

@@ -42,6 +42,7 @@ public function testMarshalling(): void
                 'fairness_key' => '',
                 'fairness_weight' => 0.0,
             ],
+            'RetryPolicy' => null,
         ];
 
         $this->assertSame($expected, $this->marshal($dto));