This commit is contained in:
Nuno Campos
2024-05-31 13:23:04 -07:00
parent 9fd459c7fc
commit 9c513ee7e6
3 changed files with 8 additions and 11 deletions
+1 -3
View File
@@ -113,9 +113,7 @@ class Branch(NamedTuple):
if any(dest is None or dest == START for dest in destinations):
raise ValueError("Branch did not return a valid destination")
if any(p.node == END for p in destinations if isinstance(p, Packet)):
raise InvalidUpdateError(
"Cannot send a packet with keyword arguments to the END node"
)
raise InvalidUpdateError("Cannot send a packet to the END node")
return writer(destinations) or input
+6 -7
View File
@@ -68,17 +68,16 @@ def map_debug_tasks(
if config is not None and TAG_HIDDEN in config.get("tags", []):
continue
payload = {
"id": str(uuid5(TASK_NAMESPACE, json.dumps((name, step, idx)))),
"name": name,
"input": input,
"triggers": triggers,
}
yield {
"type": "task",
"timestamp": ts,
"step": step,
"payload": payload,
"payload": {
"id": str(uuid5(TASK_NAMESPACE, json.dumps((name, step, idx)))),
"name": name,
"input": input,
"triggers": triggers,
},
}
+1 -1
View File
@@ -1,6 +1,6 @@
from __future__ import annotations
from typing import Any, Callable, Dict, Mapping, Optional, Sequence, Union
from typing import Any, Callable, Mapping, Optional, Sequence, Union
from langchain_core.pydantic_v1 import Field
from langchain_core.runnables import (