punchpipe.control.tests.test_processor

Attributes

TESTDATA_DIR
db
db_out_exists
db_empty

Functions

session_fn(session)
session_fn_out_file_already_exists(session)
empty_core_flow()
empty_flow(flow_id[, pipeline_config_path, session])
test_generic_process_flow_fails_on_empty_db(db_empty)
test_generic_process_flow_fails_on_out_file_existence(...)
test_simple_generic_process_flow_unreported(db)
normal_core_flow()
normal_flow(flow_id[, pipeline_config_path, session])
test_simple_generic_process_flow_normal_return(db)

Module Contents

punchpipe.control.tests.test_processor.TESTDATA_DIR

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

punchpipe.control.tests.test_processor.session_fn_out_file_already_exists(session)

punchpipe.control.tests.test_processor.db

punchpipe.control.tests.test_processor.db_out_exists

punchpipe.control.tests.test_processor.db_empty

punchpipe.control.tests.test_processor.empty_core_flow()

punchpipe.control.tests.test_processor.empty_flow(flow_id: int, pipeline_config_path=TESTDATA_DIR + '/punchpipe_config.yaml', session=None)

punchpipe.control.tests.test_processor.test_generic_process_flow_fails_on_empty_db(db_empty)

punchpipe.control.tests.test_processor.test_generic_process_flow_fails_on_out_file_existence(db_out_exists)

punchpipe.control.tests.test_processor.test_simple_generic_process_flow_unreported(db)

punchpipe.control.tests.test_processor.normal_core_flow()

punchpipe.control.tests.test_processor.normal_flow(flow_id: int, pipeline_config_path=TESTDATA_DIR + '/punchpipe_config.yaml', session=None)

punchpipe.control.tests.test_processor.test_simple_generic_process_flow_normal_return(db)