diff --git a/src/context/requirements.in b/src/context/requirements.in
index 83ae02faf4e366afee12106839db641f19554f49..e4bb209c7f01e6173e764a870d24900622b2f748 100644
--- a/src/context/requirements.in
+++ b/src/context/requirements.in
@@ -1,3 +1,4 @@
+nats-py==2.2.0
 psycopg2-binary==2.9.3
 SQLAlchemy==1.4.40
 sqlalchemy-cockroachdb==1.4.3
diff --git a/src/context/tests/test_topology.py b/src/context/tests/test_topology.py
index 2e7e38cb13c69efaeb9b3515cfb6e38ab1c14243..c9fd6870182d44cbdd93e7c67c48f51e4a979372 100644
--- a/src/context/tests/test_topology.py
+++ b/src/context/tests/test_topology.py
@@ -32,11 +32,13 @@ def test_topology(context_client : ContextClient) -> None:
     time.sleep(3) # wait for the events collector to start
 
     # ----- Prepare dependencies for the test and capture related events -----------------------------------------------
-    context_client.SetContext(Context(**CONTEXT))
+    response = context_client.SetContext(Context(**CONTEXT))
+    context_uuid = response.context_uuid.uuid
 
     event = events_collector.get_event(block=True, timeout=1.0)
     assert isinstance(event, ContextEvent)
     assert event.event.event_type == EventTypeEnum.EVENTTYPE_CREATE
+    assert event.context_id.context_uuid.uuid == context_uuid
 
     # ----- Get when the object does not exist -------------------------------------------------------------------------
     topology_id = TopologyId(**TOPOLOGY_ID)