Function test_multi_explicit_fail

tests/test_wal_transfer.py:137–155

Model a failure of the explicit segment under concurrency.

()

def test_multi_explicit_fail():
    """Model a failure of the explicit segment under concurrency."""
    group = worker.WalTransferGroup(FakeWalUploader())
    segments = list(prepare_multi_upload_segments())

    exp = Explosion('fail')
    segments[0]._upload_explosive = exp

    for seg in segments:
        group.start(seg)

    with pytest.raises(Explosion) as e:
        group.join()

    assert e.value is exp
    assert failed(segments[0])

    for seg in segments[1:]:
        assert success(seg)


def test_multi_pipeline_fail():