mirror of
https://github.com/hwchase17/langchain.git
synced 2025-09-02 19:47:13 +00:00
In Runnable.stream_log build up final_output from adding output chunks (#12781)
Add arg to omit streamed_output list, in cases where final_output is enough this saves bandwidth <!-- Thank you for contributing to LangChain! Replace this entire comment with: - **Description:** a description of the change, - **Issue:** the issue # it fixes (if applicable), - **Dependencies:** any dependencies required for this change, - **Tag maintainer:** for a quicker response, tag the relevant maintainer (see below), - **Twitter handle:** we announce bigger features on Twitter. If your PR gets announced, and you'd like a mention, we'll gladly shout you out! Please make sure your PR is passing linting and testing before submitting. Run `make format`, `make lint` and `make test` to check this locally. See contribution guidelines for more information on how to write/run tests, lint, etc: https://github.com/langchain-ai/langchain/blob/master/.github/CONTRIBUTING.md If you're adding a new integration, please include: 1. a test for the integration, preferably unit tests that do not rely on network access, 2. an example notebook showing its use. It lives in `docs/extras` directory. If no one reviews your PR within a few days, please @-mention one of @baskaryan, @eyurtsev, @hwchase17. -->
This commit is contained in:
@@ -1,6 +1,7 @@
|
||||
from langchain_core.runnables import __all__
|
||||
|
||||
EXPECTED_ALL = [
|
||||
"AddableDict",
|
||||
"ConfigurableField",
|
||||
"ConfigurableFieldSingleOption",
|
||||
"ConfigurableFieldMultiOption",
|
||||
@@ -20,6 +21,7 @@ EXPECTED_ALL = [
|
||||
"RunnableSequence",
|
||||
"RunnableWithFallbacks",
|
||||
"get_config_list",
|
||||
"aadd",
|
||||
"add",
|
||||
]
|
||||
|
||||
|
@@ -49,6 +49,7 @@ from langchain_core.prompts import (
|
||||
from langchain_core.pydantic_v1 import BaseModel
|
||||
from langchain_core.retrievers import BaseRetriever
|
||||
from langchain_core.runnables import (
|
||||
AddableDict,
|
||||
ConfigurableField,
|
||||
ConfigurableFieldMultiOption,
|
||||
ConfigurableFieldSingleOption,
|
||||
@@ -1542,6 +1543,7 @@ async def test_prompt() -> None:
|
||||
|
||||
assert stream_log[1:] == [
|
||||
RunLogPatch(
|
||||
{"op": "add", "path": "/streamed_output/-", "value": expected},
|
||||
{
|
||||
"op": "replace",
|
||||
"path": "/final_output",
|
||||
@@ -1551,9 +1553,8 @@ async def test_prompt() -> None:
|
||||
HumanMessage(content="What is your name?"),
|
||||
]
|
||||
),
|
||||
}
|
||||
},
|
||||
),
|
||||
RunLogPatch({"op": "add", "path": "/streamed_output/-", "value": expected}),
|
||||
]
|
||||
|
||||
stream_log_state = [
|
||||
@@ -1612,6 +1613,7 @@ async def test_prompt() -> None:
|
||||
|
||||
assert stream_log_nested[1:] == [
|
||||
RunLogPatch(
|
||||
{"op": "add", "path": "/streamed_output/-", "value": expected},
|
||||
{
|
||||
"op": "replace",
|
||||
"path": "/final_output",
|
||||
@@ -1621,9 +1623,8 @@ async def test_prompt() -> None:
|
||||
HumanMessage(content="What is your name?"),
|
||||
]
|
||||
),
|
||||
}
|
||||
},
|
||||
),
|
||||
RunLogPatch({"op": "add", "path": "/streamed_output/-", "value": expected}),
|
||||
]
|
||||
|
||||
|
||||
@@ -2107,9 +2108,9 @@ async def test_prompt_with_llm(
|
||||
"value": "2023-01-01T00:00:00.000",
|
||||
},
|
||||
),
|
||||
RunLogPatch({"op": "add", "path": "/streamed_output/-", "value": "foo"}),
|
||||
RunLogPatch(
|
||||
{"op": "replace", "path": "/final_output", "value": {"output": "foo"}}
|
||||
{"op": "add", "path": "/streamed_output/-", "value": "foo"},
|
||||
{"op": "replace", "path": "/final_output", "value": "foo"},
|
||||
),
|
||||
]
|
||||
|
||||
@@ -2154,6 +2155,71 @@ async def test_stream_log_retriever() -> None:
|
||||
]
|
||||
|
||||
|
||||
@freeze_time("2023-01-01")
|
||||
async def test_stream_log_lists() -> None:
|
||||
async def list_producer(input: AsyncIterator[Any]) -> AsyncIterator[AddableDict]:
|
||||
for i in range(4):
|
||||
yield AddableDict(alist=[str(i)])
|
||||
|
||||
chain: Runnable = RunnableGenerator(list_producer)
|
||||
|
||||
stream_log = [
|
||||
part async for part in chain.astream_log({"question": "What is your name?"})
|
||||
]
|
||||
|
||||
# remove ids from logs
|
||||
for part in stream_log:
|
||||
for op in part.ops:
|
||||
if (
|
||||
isinstance(op["value"], dict)
|
||||
and "id" in op["value"]
|
||||
and not isinstance(op["value"]["id"], list) # serialized lc id
|
||||
):
|
||||
del op["value"]["id"]
|
||||
|
||||
assert stream_log == [
|
||||
RunLogPatch(
|
||||
{
|
||||
"op": "replace",
|
||||
"path": "",
|
||||
"value": {"final_output": None, "logs": {}, "streamed_output": []},
|
||||
}
|
||||
),
|
||||
RunLogPatch(
|
||||
{"op": "add", "path": "/streamed_output/-", "value": {"alist": ["0"]}},
|
||||
{"op": "replace", "path": "/final_output", "value": {"alist": ["0"]}},
|
||||
),
|
||||
RunLogPatch(
|
||||
{"op": "add", "path": "/streamed_output/-", "value": {"alist": ["1"]}},
|
||||
{"op": "add", "path": "/final_output/alist/1", "value": "1"},
|
||||
),
|
||||
RunLogPatch(
|
||||
{"op": "add", "path": "/streamed_output/-", "value": {"alist": ["2"]}},
|
||||
{"op": "add", "path": "/final_output/alist/2", "value": "2"},
|
||||
),
|
||||
RunLogPatch(
|
||||
{"op": "add", "path": "/streamed_output/-", "value": {"alist": ["3"]}},
|
||||
{"op": "add", "path": "/final_output/alist/3", "value": "3"},
|
||||
),
|
||||
]
|
||||
|
||||
state = add(stream_log)
|
||||
|
||||
assert isinstance(state, RunLog)
|
||||
|
||||
assert state.state == {
|
||||
"final_output": {"alist": ["0", "1", "2", "3"]},
|
||||
"logs": {},
|
||||
"streamed_output": [
|
||||
{"alist": ["0"]},
|
||||
{"alist": ["1"]},
|
||||
{"alist": ["2"]},
|
||||
{"alist": ["3"]},
|
||||
],
|
||||
}
|
||||
|
||||
|
||||
@pytest.mark.asyncio
|
||||
@freeze_time("2023-01-01")
|
||||
async def test_prompt_with_llm_and_async_lambda(
|
||||
mocker: MockerFixture, snapshot: SnapshotAssertion
|
||||
|
Reference in New Issue
Block a user