Unverified Commit 78aa341d authored by Russell Bryant's avatar Russell Bryant Committed by GitHub
Browse files

[CI] Fix race condition in test_kv_cache_events test (#18169)


Signed-off-by: default avatarRussell Bryant <rbryant@redhat.com>
parent 79747367
...@@ -292,7 +292,6 @@ def test_kv_cache_events( ...@@ -292,7 +292,6 @@ def test_kv_cache_events(
log_stats=False, log_stats=False,
) )
endpoint = publisher_config.endpoint.replace("*", "127.0.0.1") endpoint = publisher_config.endpoint.replace("*", "127.0.0.1")
time.sleep(0.1)
subscriber = MockSubscriber(endpoint, subscriber = MockSubscriber(endpoint,
topic=publisher_config.topic, topic=publisher_config.topic,
decode_type=KVEventBatch) decode_type=KVEventBatch)
......
...@@ -130,6 +130,7 @@ class ZmqEventPublisher(EventPublisher): ...@@ -130,6 +130,7 @@ class ZmqEventPublisher(EventPublisher):
self._endpoint = endpoint self._endpoint = endpoint
self._replay_endpoint = replay_endpoint self._replay_endpoint = replay_endpoint
self._hwm = hwm self._hwm = hwm
self._socket_setup()
# Payload # Payload
self._seq_gen = count() self._seq_gen = count()
...@@ -207,7 +208,6 @@ class ZmqEventPublisher(EventPublisher): ...@@ -207,7 +208,6 @@ class ZmqEventPublisher(EventPublisher):
def _publisher_thread(self) -> None: def _publisher_thread(self) -> None:
"""Background thread that processes the event queue.""" """Background thread that processes the event queue."""
self._pack = msgspec.msgpack.Encoder() self._pack = msgspec.msgpack.Encoder()
self._socket_setup()
assert self._pub is not None # narrows type for mypy assert self._pub is not None # narrows type for mypy
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment