Changeset View
Changeset View
Standalone View
Standalone View
swh/journal/tests/test_pytest_plugin.py
| Show First 20 Lines • Show All 44 Lines • ▼ Show 20 Lines | ): | ||||
| assert topics == { | assert topics == { | ||||
| f"{kafka_prefix}_privileged.{obj}" for obj in privileged_object_types | 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): | def test_test_config(test_config: dict, kafka_prefix: str, kafka_server_base: str): | ||||
| assert test_config == { | assert test_config == { | ||||
| "consumer_id": "swh.journal.consumer", | "consumer_id": "swh.journal.consumer", | ||||
| "stop_after_objects": 1, | "stop_on_eof": True, | ||||
| "storage": {"cls": "memory", "args": {}}, | "storage": {"cls": "memory", "args": {}}, | ||||
| "object_types": { | "object_types": { | ||||
| "content", | "content", | ||||
| "directory", | "directory", | ||||
| "extid", | "extid", | ||||
| "metadata_authority", | "metadata_authority", | ||||
| "metadata_fetcher", | "metadata_fetcher", | ||||
| "origin", | "origin", | ||||
| Show All 12 Lines | |||||