From f01f4a809e8b273b1adbeadfd1e9130f1a536ae0 Mon Sep 17 00:00:00 2001 From: Gabriel Luiz Freitas Almeida Date: Fri, 22 Sep 2023 10:45:02 -0300 Subject: [PATCH] =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20?= =?UTF-8?q?langchain=5Fobject=20variable=20to=20graph=20for=20better=20cla?= =?UTF-8?q?rity=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain?= =?UTF-8?q?=5Fobject=20variable=20to=20built=5Fobject=20to=20improve=20sem?= =?UTF-8?q?antics=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langcha?= =?UTF-8?q?in=5Fobject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity=20?= =?UTF-8?q?=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fobje?= =?UTF-8?q?ct=20variable=20to=20built=5Fobject=20to=20improve=20semantics?= =?UTF-8?q?=20=F0=9F=94=A8=20refactor(worker.py):=20rename=20langchain=5Fo?= =?UTF-8?q?bject=20variable=20to=20graph=20for=20better=20clarity?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/backend/langflow/worker.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/backend/langflow/worker.py b/src/backend/langflow/worker.py index 018cfa5e7..92f6f1f7c 100644 --- a/src/backend/langflow/worker.py +++ b/src/backend/langflow/worker.py @@ -1,6 +1,8 @@ from langflow.core.celery_app import celery_app from typing import Any, Dict, Optional, Tuple from typing import TYPE_CHECKING + +from langflow.interface.run import build_sorted_vertices from celery.exceptions import SoftTimeLimitExceeded # type: ignore from langflow.processing.process import ( Result, @@ -50,11 +52,12 @@ def process_graph_cached_task( session_id=session_id, data_graph=data_graph ) # 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) - result = generate_result(langchain_object, processed_inputs) + result = generate_result(built_object, processed_inputs) # langchain_object is now updated with the new memory # 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()