Function test_multi_pipeline_fail

tests/test_wal_transfer.py:158–183

Model a failure of the pipelined segments under concurrency.

()

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

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

    for seg in segments:
        group.start(seg)

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

    assert e.value is exp

    for i, seg in enumerate(segments):
        if i == fail_idx:
            assert failed(seg)
        else:
            # Given race conditions in conjunction with exceptions --
            # which will abort waiting for other greenlets to finish
            # -- one can't know very much about the final state of
            # segment.
            assert indeterminate(seg)


def test_finally_execution():