pypushflow.tests.concurrent.test_interrupt

Functions

create_file(sleep_time, filename)
test_interrupt(scaling, max_workers, ...)