Skip to content

Commit 8beff4c

Browse files
committed
Test for double event loop case
Creating several Consumers would crash, because multiple event loops would be created. We test for this bug so it does not emerge again
1 parent 23e1301 commit 8beff4c

File tree

1 file changed

+20
-0
lines changed

1 file changed

+20
-0
lines changed

src/obelisk/sync/consumer_test.py

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,3 +11,23 @@ def test_demo_igent():
1111
)
1212

1313
assert len(result.items) == 2
14+
15+
def test_two_instances():
16+
consumer_one = Consumer(client="67c716e616c11421cfe2faf6", secret="08dafe89-0389-45b4-9832-cc565fb8c2eb")
17+
consumer_two = Consumer(client="67c716e616c11421cfe2faf6", secret="08dafe89-0389-45b4-9832-cc565fb8c2eb")
18+
result_one = consumer_one.single_chunk(
19+
datasets=["612f6c39cbceda0ea9753d95"],
20+
metrics=["org.dyamand.types.common.Temperature::number"],
21+
from_timestamp=1740924034000,
22+
to_timestamp=1741100614258,
23+
limit=2
24+
)
25+
result_two = consumer_one.single_chunk(
26+
datasets=["612f6c39cbceda0ea9753d95"],
27+
metrics=["org.dyamand.types.common.Temperature::number"],
28+
from_timestamp=1740924034000,
29+
to_timestamp=1741100614258,
30+
limit=2
31+
)
32+
assert len(result_one.items) == 2
33+
assert len(result_two.items) == 2

0 commit comments

Comments
 (0)