swh_storage = <swh.storage.postgresql.storage.Storage object at 0x7f873c610cf8> swh_storage_backend_config = {'check_config': {'check_write': True}, 'cls': 'postgresql', 'db': "user=postgres password=xxx dbname=tests host=127.0...l_writer': {'anonymize': False, 'brokers': ['127.0.0.1:44409'], 'client_id': 'kafka_writer', 'cls': 'kafka', ...}, ...} kafka_prefix = 'lwigvsccuu', kafka_server = '127.0.0.1:44409' consumer = <cimpl.Consumer object at 0x7f873c54ef48> tmp_path = PosixPath('/tmp/pytest-of-jenkins/pytest-0/test_cli_revision_from_journal0') provenance = <swh.provenance.provenance.Provenance object at 0x7f873c639278> provenance_postgresql = <connection object at 0x7f873cfb8548; dsn: 'user=postgres password=xxx dbname=provenance_tests host=127.0.0.1 port=25184 options=''', closed: 0> def test_cli_revision_from_journal_client( swh_storage: StorageInterface, swh_storage_backend_config: Dict, kafka_prefix: str, kafka_server: str, consumer: Consumer, tmp_path: str, provenance, provenance_postgresql, ) -> None: """Test revision journal client cli""" # Prepare storage data > data = load_repo_data("cmdbts2") .tox/py3/lib/python3.7/site-packages/swh/provenance/tests/test_journal_client.py:97: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ repo = 'cmdbts2' def load_repo_data(repo: str) -> Dict[str, List[dict]]: data: Dict[str, List[dict]] = {} with open(get_datafile(f"{repo}.msgpack"), "rb") as fobj: unpacker = msgpack.Unpacker( fobj, raw=False, ext_hook=msgpack_ext_hook, strict_map_key=False, timestamp=3, # convert Timestamp in datetime objects (tz UTC) ) > for objtype, objd in unpacker: E ValueError: too many values to unpack (expected 2) .tox/py3/lib/python3.7/site-packages/swh/provenance/tests/conftest.py:145: ValueError