Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix ClusterMetadata request_update() #1056

Merged
merged 11 commits into from
Oct 21, 2024
Prev Previous commit
Next Next commit
See if this makes loop available.
jackgene committed Oct 12, 2024
commit 17e5de13647652498f764801567f7a999d873c35
3 changes: 3 additions & 0 deletions tests/test_cluster.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,6 @@
import unittest

import pytest
from aiokafka.cluster import ClusterMetadata
from aiokafka.protocol.metadata import MetadataResponse
from tests._testutil import run_until_complete
@@ -22,6 +24,7 @@ def test_empty_broker_list():
)
assert len(cluster.brokers()) == 2

@pytest.mark.usefixtures("setup_test_class_serverless")
class TestClusterMetadata(unittest.TestCase):
@run_until_complete
async def test_request_update(self):