enterprise_ai.runtime.temporal
Source : sdks/python/src/enterprise_ai/runtime/temporal.py. Retour à l'index de la référence du SDK Python.
Cette page est générée par tools/docs/gen_sdk_reference.py depuis les sources du SDK et les dossiers de textes OpenAPI. Ne la modifiez pas à la main : changez la source et régénérez.
Fonctions
make_activity
make_activity(runner: AgentRunner) -> Any
Fonction d'activité : {"messages": [...]} ou {"resume": state} -> TurnResult.state().
| Nom | Type | Défaut | Requis | Description |
|---|---|---|---|---|
runner | AgentRunner | oui | Runner Navin qui exécute le tour. |
Retour : Any. Fonction payload -> dict qui envoie un heartbeat quand elle tourne dans une activité Temporal, puis exécute ou reprend un tour.
drive
drive(runner: AgentRunner, task: Any = None, system: str | None = None, messages: list[dict[str, Any]] | None = None) -> TurnResult
Exécute l'activité hors de Temporal (même déroulement que le workflow).
| Nom | Type | Défaut | Requis | Description |
|---|---|---|---|---|
runner | AgentRunner | oui | Runner Navin qui exécute le tour. | |
task | Any | None | non | Tâche ajoutée comme dernier message utilisateur. |
system | str | None | None | non | Prompt système inséré comme premier message. |
messages | list[dict[str, Any]] | None | None | non | Messages qui ouvrent déjà le tour. |
Retour : TurnResult. Un TurnResult : résultat de :meth:AgentRunner.run_turn.
build_workflow
build_workflow(runner: AgentRunner, activity_timeout: timedelta = timedelta(minutes=5)) -> tuple[type, list[Any]]
Renvoie (AgentWorkflow, activities) prêts à être enregistrés sur un worker Temporal.
| Nom | Type | Défaut | Requis | Description |
|---|---|---|---|---|
runner | AgentRunner | oui | Runner Navin appelé par l'activité. | |
activity_timeout | timedelta | timedelta(minutes=5) | non | Délai de bout en bout et de heartbeat de l'activité eai_run_turn (5 minutes par défaut). |
Retour : tuple[type, list[Any]]. Tuple de la classe EaiAgentWorkflow et de la liste contenant l'activité eai_run_turn ; lève une erreur qui cite l'extra temporal si temporalio est absent.