Handle newer jupyter_events wants string version

Author: Carreau

jupyter_server/event_schemas/contents_service/v1.yaml

@@ -1,5 +1,5 @@
 "$id": https://events.jupyter.org/jupyter_server/contents_service/v1
-version: 1
+version: "1"
 title: Contents Manager activities
 personal-data: true
 description: |

jupyter_server/event_schemas/gateway_client/v1.yaml

@@ -1,5 +1,5 @@
 "$id": https://events.jupyter.org/jupyter_server/gateway_client/v1
-version: 1
+version: "1"
 title: Gateway Client activities.
 personal-data: true
 description: |

jupyter_server/event_schemas/kernel_actions/v1.yaml

@@ -1,5 +1,5 @@
 "$id": https://events.jupyter.org/jupyter_server/kernel_actions/v1
-version: 1
+version: "1"
 title: Kernel Manager activities
 personal-data: true
 description: |

jupyter_server/services/events/handlers.py

@@ -86,9 +86,9 @@ def validate_model(
     # jupyter_events raises a useful error, so there's no need to
     # handle that case here.
     schema = registry.get(schema_id)
-    version = int(cast(int, data.get("version")))
+    version = str(cast(str, data.get("version")))
     if schema.version != version:
-        message = f"Unregistered version: {version}≠{schema.version} for `{schema_id}`"
+        message = f"Unregistered version: {version!r}≠{schema.version!r} for `{schema_id}`"
         raise Exception(message)
 
 

pyproject.toml

@@ -40,7 +40,7 @@ dependencies = [
     "tornado>=6.2.0",
     "traitlets>=5.6.0",
     "websocket-client>=1.7",
-    "jupyter_events>=0.9.0",
+    "jupyter_events>=0.11.0",
     "overrides>=5.0"
 ]
 

tests/services/events/mock_event.yaml

@@ -1,5 +1,5 @@
 $id: http://event.mock.jupyter.org/message
-version: 1
+version: "1"
 title: Message
 description: |
   Emit a message

tests/services/events/test_api.py

@@ -45,7 +45,7 @@ async def test_subscribe_websocket(event_logger, jp_ws_fetch):
 payload_1 = """\
 {
     "schema_id": "http://event.mock.jupyter.org/message",
-    "version": 1,
+    "version": "1",
     "data": {
         "event_message": "Hello, world!"
     },
@@ -56,7 +56,7 @@ async def test_subscribe_websocket(event_logger, jp_ws_fetch):
 payload_2 = """\
 {
     "schema_id": "http://event.mock.jupyter.org/message",
-    "version": 1,
+    "version": "1",
     "data": {
         "event_message": "Hello, world!"
     }
@@ -92,7 +92,7 @@ async def test_post_event(jp_fetch, event_logger_sink, payload):
 
 payload_4 = """\
 {
-    "version": 1,
+    "version": "1",
     "data": {
         "event_message": "Hello, world!"
     }
@@ -102,14 +102,14 @@ async def test_post_event(jp_fetch, event_logger_sink, payload):
 payload_5 = """\
 {
     "schema_id": "http://event.mock.jupyter.org/message",
-    "version": 1
+    "version": "1"
 }
 """
 
 payload_6 = """\
 {
     "schema_id": "event.mock.jupyter.org/message",
-    "version": 1,
+    "version": "1",
     "data": {
         "event_message": "Hello, world!"
     },
@@ -120,7 +120,7 @@ async def test_post_event(jp_fetch, event_logger_sink, payload):
 payload_7 = """\
 {
     "schema_id": "http://event.mock.jupyter.org/UNREGISTERED-SCHEMA",
-    "version": 1,
+    "version": "1",
     "data": {
         "event_message": "Hello, world!"
     }
@@ -130,7 +130,7 @@ async def test_post_event(jp_fetch, event_logger_sink, payload):
 payload_8 = """\
 {
     "schema_id": "http://event.mock.jupyter.org/message",
-    "version": 1,
+    "version": "1",
     "data": {
         "message": "Hello, world!"
     }