fix external request bug, fix tests

Signed-off-by: Lance-Drane <Lance-Drane@users.noreply.github.com>

Author: Lance-Drane

.github/workflows/ci.yml

@@ -69,7 +69,7 @@ jobs:
     runs-on: ${{ matrix.os }}
     services:
       rabbitmq:
-        image: "bitnamilegacy/rabbitmq:3.13.3"
+        image: "bitnamilegacy/rabbitmq:4.1"
         env:
           # space-delimited list of plugins
           RABBITMQ_PLUGINS: "rabbitmq_mqtt"

CHANGELOG.md

@@ -24,6 +24,7 @@ We follow [Common Changelog](https://common-changelog.org/) formatting for this
 ### Removed
 
 - Dropped MQTT 3.1.1 support ([commit](https://github.com/INTERSECT-SDK/python-sdk/commit/e09f13f9b244b92b6bcecc814df49c81340dcc02)) (Lance Drane)
+- Dropped support for Python versions <= 3.9
 
 ## [0.8.4] - 2026-02-05
 

src/intersect_sdk/service.py

@@ -881,7 +881,7 @@ def _handle_client_message(
             )
             return
 
-        extreq = self._get_external_request(headers.message_id)
+        extreq = self._get_external_request(headers.request_id)
         if extreq is not None:
             error_msg: str | None = None
             try:

tests/integration/test_service.py

@@ -143,8 +143,8 @@ def userspace_msg_callback(
 
     assert msg[0] == b'[5,8,13]'
     # make sure header IDs were not modified
-    assert msg[2]['request_id'] == request_id
-    assert msg[2]['campaign_id'] == campaign_id
+    assert msg[2].request_id == request_id
+    assert msg[2].campaign_id == campaign_id
 
 
 # call a @staticmethod user function, which should work as normal

tests/unit/test_schema_ref_resolution.py

@@ -1,6 +1,6 @@
 import json
+from collections.abc import Iterable
 from pathlib import Path
-from typing import Iterable, List
 
 from referencing import Registry, Resource
 from referencing.exceptions import Unresolvable
@@ -30,7 +30,7 @@ def assert_refs_resolve(schema: dict) -> None:
     resource = Resource.from_contents(schema, default_specification=DRAFT202012)
     base_uri = ''
     resolver = Registry().with_resource(base_uri, resource).resolver(base_uri)
-    unresolved: List[str] = []
+    unresolved: list[str] = []
     for ref in iter_ref_values(schema):
         try:
             resolver.lookup(ref)