This commit is contained in:
Chester Curme 2025-05-08 13:03:19 -04:00
parent 3516c2c394
commit d9715ad797

View File

@ -37,13 +37,18 @@ async def test_astream() -> None:
pass
async def test_stream_usage() -> None:
model = ChatAnthropic(model_name=MODEL_NAME) # type: ignore[call-arg]
async for token in model.astream("hi"):
assert isinstance(token, AIMessageChunk)
# async def test_stream_usage() -> None:
# model = ChatAnthropic(model_name=MODEL_NAME, stream_usage=False) # type: ignore[call-arg]
# async for token in model.astream("hi"):
# assert isinstance(token, AIMessageChunk)
# assert token.usage_metadata is None
async for token in model.astream("hi"):
assert isinstance(token, AIMessageChunk)
# # check we override with kwarg
# model = ChatAnthropic(model_name=MODEL_NAME) # type: ignore[call-arg]
# assert model.stream_usage
# async for token in model.astream("hi", stream_usage=False):
# assert isinstance(token, AIMessageChunk)
# assert token.usage_metadata is None
async def test_async_stream_twice() -> None: