punchpipe.control.tests.test_launcher

Attributes

TEST_DIR
db
db_empty

Functions

session_fn(session)
flow_weights()
flow_batch_sizes()
test_gather_queued_flows(db, flow_weights, ...)
test_count_running_flows(db, flow_weights)
test_escalate_long_waiting_flows(db)
test_filter_for_launchable_flows(db, flow_weights)
test_filter_for_launchable_flows_with_max_of_1(db, ...)
test_filter_for_launchable_flows_with_max_of_0(db, ...)
test_filter_for_launchable_flows_with_empty_db(...)
test_launch_ready_flows()

Module Contents

punchpipe.control.tests.test_launcher.TEST_DIR

punchpipe.control.tests.test_launcher.session_fn(session)

punchpipe.control.tests.test_launcher.db

punchpipe.control.tests.test_launcher.db_empty

punchpipe.control.tests.test_launcher.flow_weights()

punchpipe.control.tests.test_launcher.flow_batch_sizes()

punchpipe.control.tests.test_launcher.test_gather_queued_flows(db, flow_weights, flow_batch_sizes)

punchpipe.control.tests.test_launcher.test_count_running_flows(db, flow_weights)

punchpipe.control.tests.test_launcher.test_escalate_long_waiting_flows(db)

punchpipe.control.tests.test_launcher.test_filter_for_launchable_flows(db, flow_weights)

punchpipe.control.tests.test_launcher.test_filter_for_launchable_flows_with_max_of_1(db, flow_weights, flow_batch_sizes)

punchpipe.control.tests.test_launcher.test_filter_for_launchable_flows_with_max_of_0(db, flow_weights)

punchpipe.control.tests.test_launcher.test_filter_for_launchable_flows_with_empty_db(db_empty, flow_weights)

punchpipe.control.tests.test_launcher.test_launch_ready_flows()