diff --git a/src/apify/events/_apify_event_manager.py b/src/apify/events/_apify_event_manager.py index e947cb50..55e36829 100644 --- a/src/apify/events/_apify_event_manager.py +++ b/src/apify/events/_apify_event_manager.py @@ -133,7 +133,7 @@ async def _process_platform_messages(self, ws_url: str) -> None: await self._emit_persist_state_event_rec_task.stop() self.emit(event=Event.PERSIST_STATE, event_data=EventPersistStateData(is_migrating=True)) except Exception: - logger.exception('Cannot parse Actor event', extra={'message': message}) + logger.exception('Cannot parse Actor event', extra={'raw_message': message}) except Exception: logger.exception('Error in websocket connection') if self._connected_to_platform_websocket is not None: diff --git a/tests/unit/events/test_apify_event_manager.py b/tests/unit/events/test_apify_event_manager.py index a6b9c4e9..af53fa8c 100644 --- a/tests/unit/events/test_apify_event_manager.py +++ b/tests/unit/events/test_apify_event_manager.py @@ -266,6 +266,7 @@ def listener(data: Any) -> None: async def test_unknown_event_is_logged(monkeypatch: pytest.MonkeyPatch, caplog: pytest.LogCaptureFixture) -> None: """Test that unknown events are logged and not emitted.""" + caplog.set_level(logging.INFO, logger='apify') async with ( _platform_ws_server(monkeypatch) as (connected_ws_clients, client_connected), ApifyEventManager(Configuration.get_global_configuration()),