We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cd8dfc6 commit 1435afcCopy full SHA for 1435afc
tests/distributed/test_events.py
@@ -119,13 +119,12 @@ def test_topic_filtering(publisher_config):
119
"""
120
publisher_config.replay_endpoint = None
121
122
- cfg = publisher_config.model_copy()
123
- cfg.topic = "foo"
124
- pub = EventPublisherFactory.create(cfg)
+ publisher_config.topic = "foo"
+ pub = EventPublisherFactory.create(publisher_config)
125
126
from .conftest import MockSubscriber
127
- sub_foo = MockSubscriber(cfg.endpoint, None, "foo")
128
- sub_bar = MockSubscriber(cfg.endpoint, None, "bar")
+ sub_foo = MockSubscriber(publisher_config.endpoint, None, "foo")
+ sub_bar = MockSubscriber(publisher_config.endpoint, None, "bar")
129
130
try:
131
time.sleep(0.1)
0 commit comments