chore: revert ignoring of retry events

waylayio · Apr 12, 2024 · 233f6a1 · 233f6a1
1 parent f2d5b35
commit 233f6a1
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/src/waylay/sdk/api/serialization.py b/src/waylay/sdk/api/serialization.py
@@ -381,8 +381,6 @@ async def _iter_event_stream(
     response: Response,
     response_type: type[T],
     select_path: str = "",
-    *,
-    _ignore_retry_events: bool = True,
 ) -> AsyncIterator[T]:
     _response_type = _response_type_for_status_code(response.status_code, response_type)
     content_type = response.headers.get("content-type", "")
@@ -391,8 +389,6 @@ async def _iter_event_stream(
             event = __parse_event(event_str, content_type)
             if not event:
                 continue
-            if _ignore_retry_events and len(event) == 1 and "retry" in event:
-                continue
             _deserialized_event = _deserialize(
                 _extract_selected(event, select_path), _response_type
             )