Changeset View
Changeset View
Standalone View
Standalone View
swh/journal/tests/test_replay.py
| Show All 24 Lines | |||||
| from .conftest import OBJECT_TYPE_KEYS, DUPLICATE_CONTENTS | from .conftest import OBJECT_TYPE_KEYS, DUPLICATE_CONTENTS | ||||
| from .utils import MockedJournalClient, MockedKafkaWriter | from .utils import MockedJournalClient, MockedKafkaWriter | ||||
| storage_config = { | storage_config = { | ||||
| 'cls': 'pipeline', | 'cls': 'pipeline', | ||||
| 'steps': [ | 'steps': [ | ||||
| {'cls': 'validate'}, | |||||
| {'cls': 'memory'}, | {'cls': 'memory'}, | ||||
| ] | ] | ||||
| } | } | ||||
| def make_topic(kafka_prefix: str, object_type: str) -> str: | def make_topic(kafka_prefix: str, object_type: str) -> str: | ||||
| return kafka_prefix + '.' + object_type | return kafka_prefix + '.' + object_type | ||||
| ▲ Show 20 Lines • Show All 360 Lines • Show Last 20 Lines | |||||