Module Import alias ImportFrom alias ImportFrom alias ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults body If AttributeLoad NameLoad attr body Raise AttributeLoad NameLoad attr Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str Pass decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args defaults body Expr Str Assign NameStore Call NameLoad Num Num Expr Call AttributeLoad NameLoad attr Call NameLoad Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args defaults body Expr Str Assign NameStore Call NameLoad Num Num With Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Call NameLoad Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args defaults body Expr Str Assign NameStore Call NameLoad Num Num For NameStore Call NameLoad Num body Expr Call AttributeLoad NameLoad attr Call NameLoad Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args defaults body Expr Str Assign NameStore Call NameLoad Num Num Assign NameStore Call NameLoad Num keyword Call NameLoad Str Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call NameLoad Num With Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args defaults body Expr Str Assign NameStore Call NameLoad Num Num Assign NameStore Call NameLoad Num keyword Call NameLoad Str Expr Call AttributeLoad NameLoad attr NameLoad With Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args defaults body Expr Str Assign NameStore Call NameLoad Num Num Expr Call AttributeLoad NameLoad attr With Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Call NameLoad Num decorator_list FunctionDef arguments args defaults body Assign NameStore Call NameLoad Num Num For NameStore Call NameLoad Num body Expr Call AttributeLoad NameLoad attr Call NameLoad Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args defaults body Assign NameStore Call NameLoad Num Num Assign NameStore ListComp Call NameLoad Num comprehension NameStore Call NameLoad Num Assign NameStore Call NameLoad Str Assign AttributeStore SubscriptLoad NameLoad Index Num attr NameLoad With Call AttributeLoad NameLoad attr NameLoad NameStore body For NameStore NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Assert CompareIs AttributeLoad NameLoad attr NameLoad decorator_list
N/A N/A pytest wal_e exception wal_e worker FakeTarPartition N/A object N/A N/A Implements enough protocol to test concurrency semantics. __init__ N/A N/A self num_members explosive N/A False N/A N/A N/A self _explosive explosive N/A N/A self num_members num_members N/A __len__ N/A N/A self N/A N/A N/A N/A self num_members N/A N/A FakeUploader N/A object N/A N/A A no-op uploader that makes affordance for fault injection. __call__ N/A N/A self tpart N/A N/A N/A N/A tpart _explosive N/A N/A N/A tpart _explosive N/A tpart N/A N/A Explosion N/A Exception N/A N/A Marker type of injected faults. N/A N/A make_pool N/A N/A max_concurrency max_members N/A N/A N/A Set up a pool with a FakeUploader N/A N/A N/A worker TarUploadPool N/A FakeUploader max_concurrency max_members N/A test_simple N/A N/A N/A N/A N/A Simple case of uploading one partition. N/A pool N/A make_pool 1 1 N/A N/A N/A pool put N/A FakeTarPartition 1 N/A N/A N/A pool join N/A test_not_enough_resources N/A N/A N/A N/A N/A Detect if a too-large segment can never complete. N/A pool N/A make_pool 1 1 N/A N/A N/A pytest raises N/A exception UserCritical N/A N/A N/A N/A pool put N/A FakeTarPartition 2 N/A N/A N/A pool join N/A test_simple_concurrency N/A N/A N/A N/A N/A Try a pool that cannot execute all submitted jobs at once. N/A pool N/A make_pool 1 1 N/A i N/A xrange 3 N/A N/A N/A N/A pool put N/A FakeTarPartition 1 N/A N/A N/A pool join N/A test_fault_midstream N/A N/A N/A N/A N/A Test if a previous upload fault is detected in calling .put.

    This case is seen while pipelining many uploads in excess of the
    maximum concurrency.

    NB: This test is critical as to prevent failed uploads from
    failing to notify a caller that the entire backup is incomplete.
     N/A pool N/A make_pool 1 1 N/A tpart N/A FakeTarPartition 1 explosive N/A Explosion Boom N/A N/A N/A pool put tpart N/A tpart N/A FakeTarPartition 1 N/A N/A N/A pytest raises Explosion N/A N/A N/A N/A pool put tpart N/A test_fault_join N/A N/A N/A N/A N/A Test if a fault is detected when .join is used.

    This case is seen at the end of a series of uploads.

    NB: This test is critical as to prevent failed uploads from
    failing to notify a caller that the entire backup is incomplete.
     N/A pool N/A make_pool 1 1 N/A tpart N/A FakeTarPartition 1 explosive N/A Explosion Boom N/A N/A N/A pool put tpart N/A N/A N/A pytest raises Explosion N/A N/A N/A N/A pool join N/A test_put_after_join N/A N/A N/A N/A N/A New jobs cannot be submitted after a .join

    This is mostly a re-check to detect programming errors.
     N/A pool N/A make_pool 1 1 N/A N/A N/A pool join N/A N/A N/A pytest raises N/A exception UserCritical N/A N/A N/A N/A pool put N/A FakeTarPartition 1 N/A test_pool_concurrent_success N/A N/A N/A N/A N/A pool N/A make_pool 4 4 N/A i N/A xrange 30 N/A N/A N/A N/A pool put N/A FakeTarPartition 1 N/A N/A N/A pool join N/A test_pool_concurrent_failure N/A N/A N/A N/A N/A pool N/A make_pool 4 4 N/A parts N/A N/A FakeTarPartition 1 N/A i N/A xrange 30 N/A exc N/A Explosion boom N/A N/A N/A parts N/A 27 _explosive exc N/A N/A N/A pytest raises Explosion e N/A N/A part parts N/A N/A N/A N/A pool put part N/A N/A N/A pool join N/A N/A N/A e value exc N/A