shift tabs
This commit is contained in:
@@ -39,9 +39,9 @@ class GraphBase(ABC):
|
|||||||
|
|
||||||
def text_iterator():
|
def text_iterator():
|
||||||
for _, mode, out in self.workflow.stream({"inp": nargs},
|
for _, mode, out in self.workflow.stream({"inp": nargs},
|
||||||
stream_mode=["messages", "values"],
|
stream_mode=["messages", "values"],
|
||||||
subgraphs=True,
|
subgraphs=True,
|
||||||
**kwargs):
|
**kwargs):
|
||||||
if mode == "values":
|
if mode == "values":
|
||||||
val = out.get("messages")
|
val = out.get("messages")
|
||||||
if val is not None:
|
if val is not None:
|
||||||
|
|||||||
Reference in New Issue
Block a user