setting fallback_to_env_var should be respected in api calls (#2058)
This commit is contained in:
parent
22a7b7e75f
commit
82a3733ed7
3 changed files with 9 additions and 2 deletions
|
|
@ -8,7 +8,7 @@ from sqlmodel import Session, select
|
||||||
from langflow.graph.schema import RunOutputs
|
from langflow.graph.schema import RunOutputs
|
||||||
from langflow.schema.schema import INPUT_FIELD_NAME, Record
|
from langflow.schema.schema import INPUT_FIELD_NAME, Record
|
||||||
from langflow.services.database.models.flow import Flow
|
from langflow.services.database.models.flow import Flow
|
||||||
from langflow.services.deps import get_session, session_scope
|
from langflow.services.deps import get_session, get_settings_service, session_scope
|
||||||
|
|
||||||
if TYPE_CHECKING:
|
if TYPE_CHECKING:
|
||||||
from langflow.graph.graph.base import Graph
|
from langflow.graph.graph.base import Graph
|
||||||
|
|
@ -88,7 +88,9 @@ async def run_flow(
|
||||||
inputs_components.append(input_dict.get("components", []))
|
inputs_components.append(input_dict.get("components", []))
|
||||||
types.append(input_dict.get("type", "chat"))
|
types.append(input_dict.get("type", "chat"))
|
||||||
|
|
||||||
return await graph.arun(inputs_list, inputs_components=inputs_components, types=types)
|
fallback_to_env_vars = get_settings_service().settings.fallback_to_env_var
|
||||||
|
|
||||||
|
return await graph.arun(inputs_list, inputs_components=inputs_components, types=types, fallback_to_env_vars=fallback_to_env_vars)
|
||||||
|
|
||||||
|
|
||||||
def generate_function_for_flow(
|
def generate_function_for_flow(
|
||||||
|
|
|
||||||
|
|
@ -8,6 +8,7 @@ from langflow.graph.schema import RunOutputs
|
||||||
from langflow.graph.vertex.base import Vertex
|
from langflow.graph.vertex.base import Vertex
|
||||||
from langflow.schema.graph import InputValue, Tweaks
|
from langflow.schema.graph import InputValue, Tweaks
|
||||||
from langflow.schema.schema import INPUT_FIELD_NAME
|
from langflow.schema.schema import INPUT_FIELD_NAME
|
||||||
|
from langflow.services.deps import get_settings_service
|
||||||
from langflow.services.session.service import SessionService
|
from langflow.services.session.service import SessionService
|
||||||
|
|
||||||
if TYPE_CHECKING:
|
if TYPE_CHECKING:
|
||||||
|
|
@ -49,6 +50,8 @@ async def run_graph_internal(
|
||||||
inputs_list.append({INPUT_FIELD_NAME: input_value_request.input_value})
|
inputs_list.append({INPUT_FIELD_NAME: input_value_request.input_value})
|
||||||
types.append(input_value_request.type)
|
types.append(input_value_request.type)
|
||||||
|
|
||||||
|
fallback_to_env_vars = get_settings_service().settings.fallback_to_env_var
|
||||||
|
|
||||||
run_outputs = await graph.arun(
|
run_outputs = await graph.arun(
|
||||||
inputs_list,
|
inputs_list,
|
||||||
components,
|
components,
|
||||||
|
|
@ -56,6 +59,7 @@ async def run_graph_internal(
|
||||||
outputs or [],
|
outputs or [],
|
||||||
stream=stream,
|
stream=stream,
|
||||||
session_id=session_id_str or "",
|
session_id=session_id_str or "",
|
||||||
|
fallback_to_env_vars=fallback_to_env_vars
|
||||||
)
|
)
|
||||||
if session_id_str and session_service:
|
if session_id_str and session_service:
|
||||||
await session_service.update_session(session_id_str, (graph, artifacts))
|
await session_service.update_session(session_id_str, (graph, artifacts))
|
||||||
|
|
|
||||||
|
|
@ -78,6 +78,7 @@ class Settings(BaseSettings):
|
||||||
langchain_cache: str = "InMemoryCache"
|
langchain_cache: str = "InMemoryCache"
|
||||||
load_flows_path: Optional[str] = None
|
load_flows_path: Optional[str] = None
|
||||||
|
|
||||||
|
|
||||||
# Redis
|
# Redis
|
||||||
redis_host: str = "localhost"
|
redis_host: str = "localhost"
|
||||||
redis_port: int = 6379
|
redis_port: int = 6379
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue