feat: Expose RetryPolicy in Workflow context

Author: roxblnfk

src/Common/RetryOptions.php

@@ -17,6 +17,7 @@
 use Temporal\Api\Common\V1\RetryPolicy;
 use Temporal\Internal\Assert;
 use Temporal\Internal\Marshaller\Meta\Marshal;
+use Temporal\Internal\Marshaller\Type\DateIntervalType;
 use Temporal\Internal\Marshaller\Type\DurationJsonType;
 use Temporal\Internal\Support\DateInterval;
 use Temporal\Internal\Support\Options;
@@ -68,6 +69,7 @@ class RetryOptions extends Options
      * is 1.0 then it is used for all retries.
      */
     #[Marshal(name: 'initial_interval', type: DurationJsonType::class, nullable: true)]
+    #[Marshal(name: 'InitialInterval', type: DurationJsonType::class, nullable: true)]
     public ?\DateInterval $initialInterval = self::DEFAULT_INITIAL_INTERVAL;
 
     /**
@@ -77,6 +79,7 @@ class RetryOptions extends Options
      * Note: Must be greater than 1.0
      */
     #[Marshal(name: 'backoff_coefficient')]
+    #[Marshal(name: 'BackoffCoefficient')]
     public float $backoffCoefficient = self::DEFAULT_BACKOFF_COEFFICIENT;
 
     /**
@@ -86,6 +89,7 @@ class RetryOptions extends Options
      * Default is 100x of {@see $initialInterval}.
      */
     #[Marshal(name: 'maximum_interval', type: DurationJsonType::class, nullable: true)]
+    #[Marshal(name: 'MaximumInterval', type: DurationJsonType::class, nullable: true)]
     public ?\DateInterval $maximumInterval = self::DEFAULT_MAXIMUM_INTERVAL;
 
     /**
@@ -96,6 +100,7 @@ class RetryOptions extends Options
      * @var int<0, max>
      */
     #[Marshal(name: 'maximum_attempts')]
+    #[Marshal(name: 'MaximumAttempts')]
     public int $maximumAttempts = self::DEFAULT_MAXIMUM_ATTEMPTS;
 
     /**
@@ -105,6 +110,7 @@ class RetryOptions extends Options
      * @var ExceptionsList
      */
     #[Marshal(name: 'non_retryable_error_types')]
+    #[Marshal(name: 'NonRetryableErrorTypes')]
     public array $nonRetryableExceptions = self::DEFAULT_NON_RETRYABLE_EXCEPTIONS;
 
     public function mergeWith(?MethodRetry $retry = null): self

src/Internal/Marshaller/MarshallingRule.php

@@ -13,9 +13,6 @@
 
 use Temporal\Internal\Marshaller\Type\TypeInterface;
 
-/**
- * @internal
- */
 class MarshallingRule
 {
     /**

src/Workflow/WorkflowInfo.php

@@ -16,6 +16,7 @@
 use Temporal\Client\ClientOptions;
 use Temporal\Common\CronSchedule;
 use Temporal\Common\Priority;
+use Temporal\Common\RetryOptions;
 use Temporal\Common\TypedSearchAttributes;
 use Temporal\Internal\Marshaller\Meta\Marshal;
 use Temporal\Internal\Marshaller\Type\ArrayType;
@@ -143,6 +144,12 @@ final class WorkflowInfo
     #[Marshal(name: 'Priority')]
     public Priority $priority;
 
+    /**
+     * @since SDK 2.16.0
+     */
+    #[Marshal(name: 'RetryPolicy')]
+    public ?RetryOptions $retryPolicy = null;
+
     /**
      * WorkflowInfo constructor.
      */

tests/Acceptance/Extra/Workflow/RootWorkflowExecutionTest.php

@@ -0,0 +1,84 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Temporal\Tests\Acceptance\Extra\Workflow\WorkflowInfo;
+
+use PHPUnit\Framework\Attributes\Test;
+use Temporal\Client\WorkflowStubInterface;
+use Temporal\Tests\Acceptance\App\Attribute\RetryOptions;
+use Temporal\Tests\Acceptance\App\Attribute\Stub;
+use Temporal\Tests\Acceptance\App\TestCase;
+use Temporal\Workflow;
+use Temporal\Workflow\WorkflowInterface;
+use Temporal\Workflow\WorkflowMethod;
+
+class WorkflowInfoTest extends TestCase
+{
+    #[Test]
+    public static function rootWorkflowExecution(
+        #[Stub('Extra_Workflow_WorkflowInfo', args: [MainWorkflow::ARG_ROOT_EXECUTION])]
+        WorkflowStubInterface $stub,
+    ): void {
+        $result = $stub->getResult(type: 'array');
+        self::assertSame([
+            'ID' => $stub->getExecution()->getID(),
+            'RunID' => $stub->getExecution()->getRunID(),
+        ], $result);
+    }
+
+    #[Test]
+    public static function retryPolicy(
+        #[Stub('Extra_Workflow_WorkflowInfo', args: [MainWorkflow::ARG_RETRY_POLICY], retryOptions: new RetryOptions(
+            backoffCoefficient: 3.0,
+            maximumInterval: '2 minutes',
+            maximumAttempts: 10,
+        ))]
+        WorkflowStubInterface $stub,
+    ): void {
+        $result = $stub->getResult(type: 'array');
+        self::assertEquals([
+            "initial_interval" => ['seconds' => 1, 'nanos' => 0],
+            "backoff_coefficient" => 3,
+            "maximum_interval" => ['seconds' => 120, 'nanos' => 0],
+            "maximum_attempts" => 10,
+            "non_retryable_error_types" => [],
+        ], $result);
+    }
+}
+
+#[WorkflowInterface]
+class MainWorkflow
+{
+    public const ARG_RETRY_POLICY = 'retryPolicy';
+    public const ARG_ROOT_EXECUTION = 'rootExecution';
+
+    #[WorkflowMethod('Extra_Workflow_WorkflowInfo')]
+    public function run($arg)
+    {
+        return yield match ($arg) {
+            self::ARG_ROOT_EXECUTION => Workflow::newChildWorkflowStub(ChildWorkflow::class)->run(),
+            self::ARG_RETRY_POLICY => Workflow::getCurrentContext()->getInfo()->retryPolicy,
+        };
+    }
+}
+
+#[WorkflowInterface]
+class ChildWorkflow
+{
+    #[WorkflowMethod('Extra_Workflow_WorkflowInfo_Child')]
+    public function run()
+    {
+        return yield Workflow::newChildWorkflowStub(ChildWorkflow2::class)->run();
+    }
+}
+
+#[WorkflowInterface]
+class ChildWorkflow2
+{
+    #[WorkflowMethod('Extra_Workflow_WorkflowInfo_Child2')]
+    public function run()
+    {
+        return Workflow::getCurrentContext()->getInfo()->rootExecution;
+    }
+}