jyapayne/langflow
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

refactor: Remove unnecessary dependencies in simplified_run_flow endpoint

Browse source
This commit is contained in:
ogabrielluiz 2024-06-18 19:03:55 -03:00
commit d17f957411
1 changed files with 0 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/backend/base/langflow/api/v1/endpoints.py
View file

@ -120,12 +120,10 @@ async def simple_run_flow(
@router.post("/run/{flow_id_or_name}", response_model=RunResponse, response_model_exclude_none=True) @router.post("/run/{flow_id_or_name}", response_model=RunResponse, response_model_exclude_none=True)
async def simplified_run_flow( async def simplified_run_flow(
db: Annotated[Session, Depends(get_session)],
flow: Annotated[Flow, Depends(get_flow_by_id_or_endpoint_name)], flow: Annotated[Flow, Depends(get_flow_by_id_or_endpoint_name)],
input_request: SimplifiedAPIRequest = SimplifiedAPIRequest(), input_request: SimplifiedAPIRequest = SimplifiedAPIRequest(),
stream: bool = False, stream: bool = False,
api_key_user: User = Depends(api_key_security), api_key_user: User = Depends(api_key_security),
session_service: SessionService = Depends(get_session_service),
): ):
""" """
Executes a specified flow by ID with input customization, performance enhancements through caching, and optional data streaming. Executes a specified flow by ID with input customization, performance enhancements through caching, and optional data streaming.
@ -246,7 +244,6 @@ async def webhook_run_flow(
logger.debug("Starting background task") logger.debug("Starting background task")
background_tasks.add_task( background_tasks.add_task(
simple_run_flow, simple_run_flow,
db=db,
flow=flow, flow=flow,
input_request=input_request, input_request=input_request,
) )