Apply structural limit ECS formatting

Author: durable-workflow-ops

src/V2/Support/WorkflowExecutor.php

@@ -1359,7 +1359,10 @@ private function scheduleActivity(
         $this->logApproachingLimit(
             StructuralLimits::warnApproachingPayloadSize($serializedArguments),
             $run,
-            ['payload_site' => 'activity_input', 'activity_class' => $activityCall->activity],
+            [
+                'payload_site' => 'activity_input',
+                'activity_class' => $activityCall->activity,
+            ],
         );
         StructuralLimits::guardPayloadSize($serializedArguments);
 
@@ -1570,7 +1573,10 @@ private function scheduleChildWorkflow(
         $this->logApproachingLimit(
             StructuralLimits::warnApproachingPayloadSize($serializedChildArguments),
             $run,
-            ['payload_site' => 'child_workflow_input', 'child_workflow_class' => $childWorkflowCall->workflow],
+            [
+                'payload_site' => 'child_workflow_input',
+                'child_workflow_class' => $childWorkflowCall->workflow,
+            ],
         );
         StructuralLimits::guardPayloadSize($serializedChildArguments);
 
@@ -2257,7 +2263,10 @@ private function continueAsNew(
         $this->logApproachingLimit(
             StructuralLimits::warnApproachingPayloadSize($continueAsNewArguments),
             $run,
-            ['payload_site' => 'continue_as_new_input', 'target_workflow_class' => $workflowClass],
+            [
+                'payload_site' => 'continue_as_new_input',
+                'target_workflow_class' => $workflowClass,
+            ],
         );
         StructuralLimits::guardPayloadSize($continueAsNewArguments);
 
@@ -2508,7 +2517,9 @@ private function completeRun(WorkflowRun $run, WorkflowTask $task, mixed $result
         $this->logApproachingLimit(
             StructuralLimits::warnApproachingPayloadSize($serializedOutput),
             $run,
-            ['payload_site' => 'workflow_output'],
+            [
+                'payload_site' => 'workflow_output',
+            ],
         );
         StructuralLimits::guardPayloadSize($serializedOutput);
 
@@ -3769,7 +3780,9 @@ private function recordSearchAttributesUpserted(
         $this->logApproachingLimit(
             StructuralLimits::warnApproachingSearchAttributeSize($serializedSearchAttributes),
             $run,
-            ['payload_site' => 'search_attributes'],
+            [
+                'payload_site' => 'search_attributes',
+            ],
         );
         StructuralLimits::guardSearchAttributeSize($serializedSearchAttributes);
 
@@ -3846,7 +3859,9 @@ private function recordMemoUpserted(
         $this->logApproachingLimit(
             StructuralLimits::warnApproachingMemoSize($serializedMemo),
             $run,
-            ['payload_site' => 'memo'],
+            [
+                'payload_site' => 'memo',
+            ],
         );
         StructuralLimits::guardMemoSize($serializedMemo);
 

src/V2/WorkflowStub.php

@@ -1873,7 +1873,9 @@ private function recordAcceptedUpdateWithArguments(string $method, array $argume
                     'structural_limit_exceeded',
                     $this->commandTargetScope(),
                     $this->payloadLimitExceededCommandPayloadAttributes($updateName, $updateCodec, $e),
-                    ['arguments' => [$e->getMessage()]],
+                    [
+                        'arguments' => [$e->getMessage()],
+                    ],
                 );
 
                 return;
@@ -2232,7 +2234,9 @@ private function attemptSignalInternal(
                     $this->commandTargetScope(),
                     $this->payloadLimitExceededCommandPayloadAttributes($name, $signalCodec, $e),
                 );
-                $this->recordRejectedSignal($command, $name, [], ['arguments' => [$e->getMessage()]]);
+                $this->recordRejectedSignal($command, $name, [], [
+                    'arguments' => [$e->getMessage()],
+                ]);
 
                 return;
             }

tests/Feature/V2/V2StructuralLimitTest.php

@@ -5,8 +5,8 @@
 namespace Tests\Feature\V2;
 
 use Illuminate\Support\Facades\Log;
-use Tests\Fixtures\V2\TestContinueAsNewLargePayloadWorkflow;
 use Tests\Fixtures\V2\TestAwaitWithTimeoutWorkflow;
+use Tests\Fixtures\V2\TestContinueAsNewLargePayloadWorkflow;
 use Tests\Fixtures\V2\TestGreetingActivity;
 use Tests\Fixtures\V2\TestLargeMemoWorkflow;
 use Tests\Fixtures\V2\TestLargePayloadChildWorkflow;

tests/Unit/V2/StructuralLimitsTest.php

@@ -528,32 +528,46 @@ public function testWarnApproachingSearchAttributeSizeReturnsWarning(): void
 
     public function testLogWarningIsNoOpWhenWarningIsNull(): void
     {
-        $logger = new class extends AbstractLogger {
-            /** @var list<array{level: string, message: string, context: array}> */
+        $logger = new class() extends AbstractLogger {
+            /**
+             * @var list<array{level: string, message: string, context: array}>
+             */
             public array $records = [];
 
             public function log($level, $message, array $context = []): void
             {
-                $this->records[] = ['level' => (string) $level, 'message' => (string) $message, 'context' => $context];
+                $this->records[] = [
+                    'level' => (string) $level,
+                    'message' => (string) $message,
+                    'context' => $context,
+                ];
             }
         };
 
         Log::swap($logger);
 
-        StructuralLimits::logWarning(null, ['workflow_run_id' => 'run-1']);
+        StructuralLimits::logWarning(null, [
+            'workflow_run_id' => 'run-1',
+        ]);
 
         $this->assertSame([], $logger->records);
     }
 
     public function testLogWarningEmitsStructuredRecordWithContext(): void
     {
-        $logger = new class extends AbstractLogger {
-            /** @var list<array{level: string, message: string, context: array}> */
+        $logger = new class() extends AbstractLogger {
+            /**
+             * @var list<array{level: string, message: string, context: array}>
+             */
             public array $records = [];
 
             public function log($level, $message, array $context = []): void
             {
-                $this->records[] = ['level' => (string) $level, 'message' => (string) $message, 'context' => $context];
+                $this->records[] = [
+                    'level' => (string) $level,
+                    'message' => (string) $message,
+                    'context' => $context,
+                ];
             }
         };