| """Integration test topologies""" | |
| __all__ = [ | |
| 'all_grouping', | |
| 'basic_one_task' | |
| 'bolt_double_emit_tuples', | |
| 'fields_grouping', | |
| 'global_grouping', | |
| 'multi_spouts_multi_tasks', | |
| 'none_grouping', | |
| 'one_bolt_multi_tasks', | |
| 'one_spout_bolt_multi_tasks', | |
| 'one_spout_multi_tasks', | |
| 'one_spout_two_bolts', | |
| 'shuffle_grouping', | |
| ] | |
| # import some core stuff | |
| import integration_test.src.python.integration_test.common as common | |
| import integration_test.src.python.integration_test.core as core |