Differential D3654 Diff 12891 swh/journal/tests/test_pytest_plugin.py

Changeset View

Standalone View

	Show First 20 Lines • Show All 48 Lines • ▼ Show 20 Lines
	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_after_objects": 1,
	"storage": {"cls": "memory", "args": {}},			"storage": {"cls": "memory", "args": {}},
	"object_types": {			"object_types": {
	"content",			"content",
	"directory",			"directory",
				"metadata_authority",
				"metadata_fetcher",
	"origin",			"origin",
	"origin_visit",			"origin_visit",
	"origin_visit_status",			"origin_visit_status",
				"raw_extrinsic_metadata",
	"release",			"release",
	"revision",			"revision",
	"snapshot",			"snapshot",
	"skipped_content",			"skipped_content",
	},			},
	"privileged_object_types": {"release", "revision",},			"privileged_object_types": {"release", "revision",},
	"brokers": [kafka_server_base],			"brokers": [kafka_server_base],
	"prefix": kafka_prefix,			"prefix": kafka_prefix,
	}			}