self = <swh.storage.tests.test_storage.TestStorage object at 0x7f8f0e10d748> swh_storage = <swh.storage.validate.ValidatingProxyStorage object at 0x7f8f0e0a5390> def test_origin_visit_get_random(self, swh_storage): swh_storage.origin_add(data.origins) # Add some random visits within the selection range visits = self._generate_random_visits() visit_type = "git" # Add visits to those origins for origin in data.origins: origin_url = origin["url"] for date_visit in visits: visit = swh_storage.origin_visit_add( > [OriginVisit(origin=origin_url, date=date_visit, type=visit_type,)] )[0] .tox/py3/lib/python3.7/site-packages/swh/storage/tests/test_storage.py:1514: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ .tox/py3/lib/python3.7/site-packages/swh/storage/validate.py:141: in origin_visit_add return self.storage.origin_visit_add(visits) .tox/py3/lib/python3.7/site-packages/swh/storage/metrics.py:24: in d return f(*a, **kw) .tox/py3/lib/python3.7/site-packages/swh/core/db/common.py:62: in _meth return meth(self, *args, db=db, cur=cur, **kwargs) .tox/py3/lib/python3.7/site-packages/swh/storage/storage.py:833: in origin_visit_add self._origin_visit_status_add(visit_status, db=db, cur=cur) .tox/py3/lib/python3.7/site-packages/swh/storage/storage.py:842: in _origin_visit_status_add self.journal_writer.origin_visit_status_add([visit_status]) .tox/py3/lib/python3.7/site-packages/swh/storage/writer.py:85: in origin_visit_status_add self.write_additions("origin_visit_status", visit_statuses) .tox/py3/lib/python3.7/site-packages/swh/storage/writer.py:48: in write_additions self.journal.write_additions(obj_type, values) .tox/py3/lib/python3.7/site-packages/swh/journal/writer/inmemory.py:40: in write_additions self.write_addition(object_type, object_, privileged) .tox/py3/lib/python3.7/site-packages/swh/journal/writer/inmemory.py:32: in write_addition self.objects.append((object_type, object_)) <string>:2: in append ??? /usr/lib/python3.7/multiprocessing/managers.py:796: in _callmethod kind, result = conn.recv() /usr/lib/python3.7/multiprocessing/connection.py:250: in recv buf = self._recv_bytes() /usr/lib/python3.7/multiprocessing/connection.py:407: in _recv_bytes buf = self._recv(4) _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self = <multiprocessing.connection.Connection object at 0x7f8f0e050198> size = 4, read = <built-in function read> def _recv(self, size, read=_read): buf = io.BytesIO() handle = self._handle remaining = size while remaining > 0: chunk = read(handle, remaining) n = len(chunk) if n == 0: if remaining == size: > raise EOFError E EOFError /usr/lib/python3.7/multiprocessing/connection.py:383: EOFError