pypushflow.tests.concurrent.test_interrupt

Functions

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