From f4282b0016b1c64e39ad42a18733a62d55d01f0c Mon Sep 17 00:00:00 2001
From: Jan Buchar <Teyras@gmail.com>
Date: Fri, 30 Aug 2024 17:49:26 +0200
Subject: [PATCH] Ignore deprecated platform events

---
 src/apify/_platform_event_manager.py | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/src/apify/_platform_event_manager.py b/src/apify/_platform_event_manager.py
index 17f00480..88bab198 100644
--- a/src/apify/_platform_event_manager.py
+++ b/src/apify/_platform_event_manager.py
@@ -94,6 +94,11 @@ class EventWithoutData(BaseModel):
     data: Any = None
 
 
+class DeprecatedEvent(BaseModel):
+    name: Literal['cpuInfo']
+    data: Annotated[dict[str, Any], Field(default_factory=dict)]
+
+
 class UnknownEvent(BaseModel):
     name: str
     data: Annotated[dict[str, Any], Field(default_factory=dict)]
@@ -109,12 +114,13 @@ class UnknownEvent(BaseModel):
 ]
 
 
-event_data_adapter: TypeAdapter[EventMessage | UnknownEvent] = TypeAdapter(
+event_data_adapter: TypeAdapter[EventMessage | DeprecatedEvent | UnknownEvent] = TypeAdapter(
     Union[
         Annotated[
             EventMessage,
             Discriminator('name'),
         ],
+        DeprecatedEvent,
         UnknownEvent,
     ]
 )
@@ -189,6 +195,9 @@ async def _process_platform_messages(self, ws_url: str) -> None:
                     try:
                         parsed_message = event_data_adapter.validate_json(message)
 
+                        if isinstance(parsed_message, DeprecatedEvent):
+                            continue
+
                         if isinstance(parsed_message, UnknownEvent):
                             logger.info(
                                 f'Unknown message received: event_name={parsed_message.name}, '