Page MenuHomeSoftware Heritage
Files F9342174

No OneTemporary
Actions

View Options

diff --git a/swh/journal/tests/test_pytest_plugin.py b/swh/journal/tests/test_pytest_plugin.py
index 02c0ef7..4070714 100644
--- a/swh/journal/tests/test_pytest_plugin.py
+++ b/swh/journal/tests/test_pytest_plugin.py
@@ -1,72 +1,73 @@
# Copyright (C) 2020 The Software Heritage developers
# See the AUTHORS file at the top-level directory of this distribution
# License: GNU General Public License version 3, or any later version
# See top-level LICENSE file for more information
from typing import Iterator
from confluent_kafka.admin import AdminClient
def test_kafka_server(kafka_server_base: str):
ip, port_str = kafka_server_base.split(":")
assert ip == "127.0.0.1"
assert int(port_str)
admin = AdminClient({"bootstrap.servers": kafka_server_base})
topics = admin.list_topics()
assert len(topics.brokers) == 1
def test_kafka_server_with_topics(
kafka_server: str,
kafka_prefix: str,
object_types: Iterator[str],
privileged_object_types: Iterator[str],
):
admin = AdminClient({"bootstrap.servers": kafka_server})
# check unprivileged topics are present
topics = {
topic
for topic in admin.list_topics().topics
if topic.startswith(f"{kafka_prefix}.")
}
assert topics == {f"{kafka_prefix}.{obj}" for obj in object_types}
# check privileged topics are present
topics = {
topic
for topic in admin.list_topics().topics
if topic.startswith(f"{kafka_prefix}_privileged.")
}
assert topics == {
f"{kafka_prefix}_privileged.{obj}" for obj in privileged_object_types
}
def test_test_config(test_config: dict, kafka_prefix: str, kafka_server_base: str):
assert test_config == {
"consumer_id": "swh.journal.consumer",
"stop_after_objects": 1,
"storage": {"cls": "memory", "args": {}},
"object_types": {
"content",
"directory",
+ "extid",
"metadata_authority",
"metadata_fetcher",
"origin",
"origin_visit",
"origin_visit_status",
"raw_extrinsic_metadata",
"release",
"revision",
"snapshot",
"skipped_content",
},
"privileged_object_types": {"release", "revision",},
"brokers": [kafka_server_base],
"prefix": kafka_prefix,
}

File Metadata

Mime Type
text/x-diff
Expires
Fri, Jul 4, 12:32 PM (2 w, 3 d ago)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3271351

Event Timeline

About · Developer information · Legal