Loading src/context/requirements.in +1 −0 Original line number Diff line number Diff line nats-py==2.2.0 psycopg2-binary==2.9.3 SQLAlchemy==1.4.40 sqlalchemy-cockroachdb==1.4.3 Loading src/context/tests/test_topology.py +3 −1 Original line number Diff line number Diff line Loading @@ -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) Loading Loading
src/context/requirements.in +1 −0 Original line number Diff line number Diff line nats-py==2.2.0 psycopg2-binary==2.9.3 SQLAlchemy==1.4.40 sqlalchemy-cockroachdb==1.4.3 Loading
src/context/tests/test_topology.py +3 −1 Original line number Diff line number Diff line Loading @@ -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) Loading