Skip to content

Commit ed5ab3b

Browse files
authored
fix: Ignore deprecated platform events (#258)
1 parent 0ea57d7 commit ed5ab3b

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

src/apify/_platform_event_manager.py

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,11 @@ class EventWithoutData(BaseModel):
9494
data: Any = None
9595

9696

97+
class DeprecatedEvent(BaseModel):
98+
name: Literal['cpuInfo']
99+
data: Annotated[dict[str, Any], Field(default_factory=dict)]
100+
101+
97102
class UnknownEvent(BaseModel):
98103
name: str
99104
data: Annotated[dict[str, Any], Field(default_factory=dict)]
@@ -109,12 +114,13 @@ class UnknownEvent(BaseModel):
109114
]
110115

111116

112-
event_data_adapter: TypeAdapter[EventMessage | UnknownEvent] = TypeAdapter(
117+
event_data_adapter: TypeAdapter[EventMessage | DeprecatedEvent | UnknownEvent] = TypeAdapter(
113118
Union[
114119
Annotated[
115120
EventMessage,
116121
Discriminator('name'),
117122
],
123+
DeprecatedEvent,
118124
UnknownEvent,
119125
]
120126
)
@@ -189,6 +195,9 @@ async def _process_platform_messages(self, ws_url: str) -> None:
189195
try:
190196
parsed_message = event_data_adapter.validate_json(message)
191197

198+
if isinstance(parsed_message, DeprecatedEvent):
199+
continue
200+
192201
if isinstance(parsed_message, UnknownEvent):
193202
logger.info(
194203
f'Unknown message received: event_name={parsed_message.name}, '

0 commit comments

Comments
 (0)