self = <swh.storage.tests.test_storage.TestStorage object at 0x7f783a96eeb8> swh_storage = <swh.storage.storage.Storage object at 0x7f783bb56550> sample_data = <swh.storage.tests.storage_data.StorageData object at 0x7f783a98e1d0> def test_origin_visit_status_get_random(self, swh_storage, sample_data): origins = sample_data.origins[:2] swh_storage.origin_add(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 origins: for date_visit in visits: visit = swh_storage.origin_visit_add( [OriginVisit(origin=origin.url, date=date_visit, type=visit_type,)] )[0] swh_storage.origin_visit_status_add( [ OriginVisitStatus( origin=origin.url, visit=visit.visit, date=now(), status="full", > snapshot=None, ) ] ) .tox/py3/lib/python3.7/site-packages/swh/storage/tests/test_storage.py:1542: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ .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:864: in origin_visit_status_add self._origin_visit_status_add(visit_status, db, cur) .tox/py3/lib/python3.7/site-packages/swh/storage/storage.py:846: 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:88: in origin_visit_status_add self.write_additions("origin_visit_status", visit_statuses) .tox/py3/lib/python3.7/site-packages/swh/storage/writer.py:51: 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 0x7f783a98e5c0> 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