Flujo de trabajo de múltiples pasos

Aprende a manejar flujos de ejecución complejos orquestando la ejecución de varios nodos

Se crean varios pasos definiendo eventos personalizados que pueden ser emitidos por nodos y desencadenar otros nodos. Definamos un flujo de trabajo simple de 3 pasos.

Eventos personalizados

Definimos dos eventos personalizados, FirstEvent y SecondEvent. Estas clases pueden tener cualquier nombre y propiedades, pero deben implementar Event:

Unix

vendor/bin/neuron make:event App\\Neuron\\FirstEvent

Windows

.\vendor\bin\neuron make:event App\Neuron\FirstEvent

namespace App\Neuron;

class FirstEvent implements Event 
{
    public function __construct(protected string $firstMsg){}
}

class SecondEvent implements Event 
{
    public function __construct(protected string $secondMsg){}
}

Definición del flujo de trabajo

Ahora definimos el flujo de trabajo en sí. Lo hacemos definiendo los tipos de entrada y salida en cada nodo. Aquí está la implementación mínima de los nodos para el propósito de esta demo.

InitialNode

Unix

vendor/bin/neuron make:node App\\Neuron\\InitialNode

Windows

.\vendor\bin\neuron make:node App\Neuron\InitialNode

namespace App\Neuron;

use NeuronAI\Workflow\Node;
use NeuronAI\Workflow\StartEvent;
use App\Neuron\FirstEvent;

class InitialNode extends Node
{
    /**
     * Obtiene el "StartEvent" y devuelve "FirstEvent"
     */
    public function __invoke(StartEvent $event, WorkflowState $state): FirstEvent
    {
        echo "\n- Manejo de StartEvent";
        
        return new FirstEvent("InitialNode complete");
    }
}

NodeOne

Unix

vendor/bin/neuron make:node App\\Neuron\\NodeOne

Windows

.\vendor\bin\neuron make:node App\Neuron\NodeOne

class NodeOne extends Node
{
    /**
     * Toma "FirstEvent" como entrada y devuelve "SecondEvent"
     */
    public function __invoke(FirstEvent $event, WorkflowState $state): SecondEvent
    {
        echo "\n- ".$event->firstMsg;
        
        return new SecondEvent("NodeOne complete");
    }
}

NodeTwo

Unix

vendor/bin/neuron make:node App\\Neuron\\NodeTwo

Windows

.\vendor\bin\neuron make:node App\Neuron\NodeTwo

class NodeTwo extends Node
{
    /**
     * Toma "SecondEvent" como entrada y devuelve "StopEvent"
     */
    public function __invoke(SecondEvent $event, WorkflowState $state): StopEvent
    {
        echo "\n- ".$event->secondMsg;
        
        echo "\n- NodeTwo complete";
        
        return new StopEvent();
    }
}

Defina el flujo de trabajo adjuntando los nodos:

use NeuronAI\Workflow\Workflow;

$handler = Workflow::make()
    ->addNodes([
        new InitialNode(),
        new NodeOne(),
        new NodeTwo(),
    ])
    ->init();

/*
 * Ejecute el flujo de trabajo
 */
$handler->run();

La salida completa será:

- Manejo de StartEvent
- InitialNode complete
- NodeOne complete
- NodeTwo complete

Por supuesto, todavía no tiene mucho sentido un flujo de trabajo si simplemente lo recorres de principio a fin. Hagamos algo de ramificación y bucles.

Monitoreo y depuración

Muchas de las aplicaciones que construyas con Neuron contendrán múltiples pasos con múltiples invocaciones de llamadas a LLM. A medida que estas aplicaciones se vuelven cada vez más complejas, se vuelve crucial poder inspeccionar exactamente qué está ocurriendo dentro de tu sistema agéntico. La mejor manera de hacerlo es con Inspector.

Neuron AI | Inspectordocs.inspector.dev