Rename attribute to Parallel and apply it on the tools method

Author: pushpak1300

src/Attributes/Parallel.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace Laravel\Ai\Attributes;
+
+use Attribute;
+use ReflectionMethod;
+
+#[Attribute(Attribute::TARGET_METHOD)]
+final class Parallel
+{
+    public static function isAppliedTo(?object $target): bool
+    {
+        return $target !== null
+            && method_exists($target, 'tools')
+            && (new ReflectionMethod($target, 'tools'))->getAttributes(self::class) !== [];
+    }
+}

src/Attributes/ParallelTools.php

@@ -4,7 +4,7 @@
 
 use Laravel\Ai\Attributes\MaxSteps;
 use Laravel\Ai\Attributes\MaxTokens;
-use Laravel\Ai\Attributes\ParallelTools;
+use Laravel\Ai\Attributes\Parallel;
 use Laravel\Ai\Attributes\Temperature;
 use Laravel\Ai\Attributes\TopP;
 use Laravel\Ai\Contracts\Agent;
@@ -45,7 +45,7 @@ public function providerOptions(Lab|string $provider): ?array
      */
     public function parallelTools(): bool
     {
-        return ParallelTools::isAppliedTo($this->agent);
+        return Parallel::isAppliedTo($this->agent);
     }
 
     /**

src/Gateway/TextGenerationOptions.php

@@ -6,9 +6,10 @@
 use Illuminate\Support\Arr;
 use Illuminate\Support\Defer\DeferredCallback;
 use Illuminate\Support\Facades\Concurrency;
-use Laravel\Ai\Attributes\ParallelTools;
+use Laravel\Ai\Attributes\Parallel;
 use Laravel\Ai\Contracts\Agent;
 use Laravel\Ai\Contracts\Gateway\StepTextGateway;
+use Laravel\Ai\Contracts\HasTools;
 use Laravel\Ai\Contracts\Providers\TextProvider;
 use Laravel\Ai\Contracts\Tool;
 use Laravel\Ai\Exceptions\NoSuchToolException;
@@ -26,15 +27,19 @@
 use Laravel\Ai\Tools\Request;
 use Laravel\SerializableClosure\SerializableClosure;
 
-test('the parallel tools attribute is detected on an agent', function () {
-    expect(ParallelTools::isAppliedTo(new ParallelToolsAgent))->toBeTrue()
-        ->and(ParallelTools::isAppliedTo(new SequentialToolsAgent))->toBeFalse()
-        ->and(ParallelTools::isAppliedTo(null))->toBeFalse();
+test('the parallel attribute is detected on the tools method', function () {
+    expect(Parallel::isAppliedTo(new ParallelAgent))->toBeTrue()
+        ->and(Parallel::isAppliedTo(new SequentialAgent))->toBeFalse()
+        ->and(Parallel::isAppliedTo(new class
+        {
+            // An agent without a tools() method is never parallel.
+        }))->toBeFalse()
+        ->and(Parallel::isAppliedTo(null))->toBeFalse();
 });
 
 test('forAgent resolves whether the agent runs its tools in parallel', function () {
-    expect(TextGenerationOptions::forAgent(new ParallelToolsAgent)->parallelTools())->toBeTrue()
-        ->and(TextGenerationOptions::forAgent(new SequentialToolsAgent)->parallelTools())->toBeFalse();
+    expect(TextGenerationOptions::forAgent(new ParallelAgent)->parallelTools())->toBeTrue()
+        ->and(TextGenerationOptions::forAgent(new SequentialAgent)->parallelTools())->toBeFalse();
 });
 
 test('parallel tools run together with results in original order and correctly paired events', function () {
@@ -75,7 +80,7 @@
         [],
         $tools,
         null,
-        new TextGenerationOptions(maxSteps: 2, agent: new ParallelToolsAgent),
+        new TextGenerationOptions(maxSteps: 2, agent: new ParallelAgent),
         null,
     );
 
@@ -107,7 +112,7 @@
         [],
         [new ParallelRecordingTool('solo', $log, 'S')],
         null,
-        new TextGenerationOptions(maxSteps: 2, agent: new ParallelToolsAgent),
+        new TextGenerationOptions(maxSteps: 2, agent: new ParallelAgent),
         null,
     );
 
@@ -146,7 +151,7 @@ protected function canRunInParallel(): bool
         [],
         $tools,
         null,
-        new TextGenerationOptions(maxSteps: 2, agent: new ParallelToolsAgent),
+        new TextGenerationOptions(maxSteps: 2, agent: new ParallelAgent),
         null,
     );
 
@@ -178,7 +183,7 @@ protected function canRunInParallel(): bool
         [],
         $tools,
         null,
-        new TextGenerationOptions(maxSteps: 2, agent: new ParallelToolsAgent),
+        new TextGenerationOptions(maxSteps: 2, agent: new ParallelAgent),
         null,
     ))->toThrow(RuntimeException::class, 'boom:bravo');
 });
@@ -202,7 +207,7 @@ protected function canRunInParallel(): bool
         [],
         [new ParallelRecordingTool('alpha', $log, 'A')],
         null,
-        new TextGenerationOptions(maxSteps: 2, agent: new ParallelToolsAgent),
+        new TextGenerationOptions(maxSteps: 2, agent: new ParallelAgent),
         null,
     ))->toThrow(NoSuchToolException::class)
         ->and($log->getArrayCopy())->toBe([]);
@@ -234,7 +239,7 @@ protected function canRunInParallel(): bool
         [],
         $tools,
         null,
-        new TextGenerationOptions(maxSteps: 2, agent: new ParallelToolsAgent),
+        new TextGenerationOptions(maxSteps: 2, agent: new ParallelAgent),
         null,
     ));
 
@@ -271,7 +276,7 @@ protected function canRunInParallel(): bool
         [],
         $tools,
         null,
-        new TextGenerationOptions(maxSteps: 2, agent: new ParallelToolsAgent),
+        new TextGenerationOptions(maxSteps: 2, agent: new ParallelAgent),
         null,
     );
 
@@ -320,7 +325,7 @@ protected function canRunInParallel(): bool
         [],
         $tools,
         null,
-        new TextGenerationOptions(maxSteps: 2, agent: new ParallelToolsAgent),
+        new TextGenerationOptions(maxSteps: 2, agent: new ParallelAgent),
         null,
     );
 
@@ -350,25 +355,35 @@ function parallelToolsGateway(array $steps = [], array $streams = []): ParallelT
     return new ParallelToolsFakeGateway($steps, $streams);
 }
 
-#[ParallelTools]
-class ParallelToolsAgent implements Agent
+class ParallelAgent implements Agent, HasTools
 {
     use Promptable;
 
     public function instructions(): string
     {
         return 'test';
     }
+
+    #[Parallel]
+    public function tools(): array
+    {
+        return [];
+    }
 }
 
-class SequentialToolsAgent implements Agent
+class SequentialAgent implements Agent, HasTools
 {
     use Promptable;
 
     public function instructions(): string
     {
         return 'test';
     }
+
+    public function tools(): array
+    {
+        return [];
+    }
 }
 
 class ParallelRecordingTool implements Tool