diff --git a/langserve/api_handler.py b/langserve/api_handler.py index d72f09cb..346e89dc 100644 --- a/langserve/api_handler.py +++ b/langserve/api_handler.py @@ -1245,7 +1245,7 @@ async def _stream_log() -> AsyncIterator[dict]: } # Send a metadata event as soon as possible - if not has_sent_metadata and self._enable_feedback_endpoint: + if not has_sent_metadata and self._token_feedback_enabled: if task is None: raise AssertionError("Feedback token task was not created.") if not task.done(): @@ -1354,7 +1354,7 @@ async def _stream_events() -> AsyncIterator[dict]: } # Send a metadata event as soon as possible - if not has_sent_metadata and self._enable_feedback_endpoint: + if not has_sent_metadata and self._token_feedback_enabled: if task is None: raise AssertionError("Feedback token task was not created.") if not task.done():