kafka_prefix = 'iwazrjdbmn.swh.journal.objects' kafka_server = '127.0.0.1:48181' consumer = <cimpl.Consumer object at 0x7fc4455a87b8> large_directories = [Directory(entries=[DirectoryEntry(name=b'000000000', type='file', target=b'\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x...x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00', perms=33188)], id=b').\x887-c?\x10\x9eRa\x93\t\x16\xeb_\x02\xbaRz'), ...] def test_fail_write_large_objects( kafka_prefix: str, kafka_server: str, consumer: Consumer, large_directories: List[Directory], ): kafka_prefix += ".swh.journal.objects" # Needed as there is no directories in TEST_OBJECT_DICTS, the consumer # isn't autosubscribed to directories. consumer.subscribe([kafka_prefix + ".directory"]) writer = KafkaJournalWriter( brokers=[kafka_server], client_id="kafka_writer", prefix=kafka_prefix, ) expected_dirs = [] for directory in large_directories: if dir_message_size(directory) < SMALL_MESSAGE_SIZE: # No error; write anyway, but continue writer.write_addition("directory", directory) expected_dirs.append(directory) continue with pytest.raises(KafkaDeliveryError) as exc: > writer.write_addition("directory", directory) E Failed: DID NOT RAISE <class 'swh.journal.writer.kafka.KafkaDeliveryError'> .tox/py3/lib/python3.7/site-packages/swh/journal/tests/test_kafka_writer.py:252: Failed