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

🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity

Browse source 
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
🔨 refactor(worker.py): rename langchain_object variable to built_object to improve semantics
🔨 refactor(worker.py): rename langchain_object variable to graph for better clarity
This commit is contained in:
Gabriel Luiz Freitas Almeida 2023-09-22 10:45:02 -03:00
commit f01f4a809e
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/backend/langflow/worker.py
View file

@ -1,6 +1,8 @@
from langflow.core.celery_app import celery_app from langflow.core.celery_app import celery_app
from typing import Any, Dict, Optional, Tuple from typing import Any, Dict, Optional, Tuple
from typing import TYPE_CHECKING from typing import TYPE_CHECKING
from langflow.interface.run import build_sorted_vertices
from celery.exceptions import SoftTimeLimitExceeded # type: ignore from celery.exceptions import SoftTimeLimitExceeded # type: ignore
from langflow.processing.process import ( from langflow.processing.process import (
Result, Result,
@ -50,11 +52,12 @@ def process_graph_cached_task(
session_id=session_id, data_graph=data_graph session_id=session_id, data_graph=data_graph
) )
# Load the graph using SessionService # Load the graph using SessionService
langchain_object, artifacts = session_service.load_session(session_id, data_graph) graph, artifacts = session_service.load_session(session_id, data_graph)
built_object = graph.build()
processed_inputs = process_inputs(inputs, artifacts) processed_inputs = process_inputs(inputs, artifacts)
result = generate_result(langchain_object, processed_inputs) result = generate_result(built_object, processed_inputs)
# langchain_object is now updated with the new memory # langchain_object is now updated with the new memory
# we need to update the cache with the updated langchain_object # we need to update the cache with the updated langchain_object
session_service.update_session(session_id, (langchain_object, artifacts)) session_service.update_session(session_id, (graph, artifacts))
return Result(result=result, session_id=session_id).dict() return Result(result=result, session_id=session_id).dict()