fix: graph process should raise the actual error when failing
This commit is contained in:
parent
da6bfc2ec1
commit
e45737aaaa
2 changed files with 2 additions and 1 deletions
|
|
@ -836,7 +836,7 @@ class Graph:
|
||||||
next_runnable_vertices = await self._execute_tasks(tasks, lock=lock)
|
next_runnable_vertices = await self._execute_tasks(tasks, lock=lock)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"Error executing tasks in layer {layer_index}: {e}")
|
logger.error(f"Error executing tasks in layer {layer_index}: {e}")
|
||||||
break
|
raise e
|
||||||
if not next_runnable_vertices:
|
if not next_runnable_vertices:
|
||||||
break
|
break
|
||||||
to_process.extend(next_runnable_vertices)
|
to_process.extend(next_runnable_vertices)
|
||||||
|
|
|
||||||
|
|
@ -224,6 +224,7 @@ def json_vector_store():
|
||||||
|
|
||||||
@pytest.fixture(name="client", autouse=True)
|
@pytest.fixture(name="client", autouse=True)
|
||||||
def client_fixture(session: Session, monkeypatch, request, load_flows_dir):
|
def client_fixture(session: Session, monkeypatch, request, load_flows_dir):
|
||||||
|
monkeypatch.setenv("LANGFLOW_LOG_LEVEL", "DEBUG")
|
||||||
# Set the database url to a test database
|
# Set the database url to a test database
|
||||||
if "noclient" in request.keywords:
|
if "noclient" in request.keywords:
|
||||||
yield
|
yield
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue