Merge remote-tracking branch 'origin/dev' into feature/store
This commit is contained in:
commit
580f3a1e0d
1 changed files with 5 additions and 2 deletions
|
|
@ -8,7 +8,8 @@ from langchain.chains.base import Chain
|
||||||
from langchain.schema import AgentAction, Document
|
from langchain.schema import AgentAction, Document
|
||||||
from langchain.vectorstores.base import VectorStore
|
from langchain.vectorstores.base import VectorStore
|
||||||
from langflow.graph import Graph
|
from langflow.graph import Graph
|
||||||
from langflow.interface.run import build_sorted_vertices, get_memory_key, update_memory_keys
|
from langflow.interface.run import (build_sorted_vertices, get_memory_key,
|
||||||
|
update_memory_keys)
|
||||||
from langflow.services.deps import get_session_service
|
from langflow.services.deps import get_session_service
|
||||||
from loguru import logger
|
from loguru import logger
|
||||||
from pydantic import BaseModel
|
from pydantic import BaseModel
|
||||||
|
|
@ -111,7 +112,9 @@ def process_inputs(inputs: Optional[dict], artifacts: Dict[str, Any]) -> dict:
|
||||||
inputs = {}
|
inputs = {}
|
||||||
|
|
||||||
for key, value in artifacts.items():
|
for key, value in artifacts.items():
|
||||||
if key not in inputs or not inputs[key]:
|
if key == "repr":
|
||||||
|
continue
|
||||||
|
elif key not in inputs or not inputs[key]:
|
||||||
inputs[key] = value
|
inputs[key] = value
|
||||||
|
|
||||||
return inputs
|
return inputs
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue