run ModuleProcessor for each modules :param configuration: user final configuration :return:
(configuration)
| 543 | |
| 544 | |
| 545 | def run_modules_processors(configuration): |
| 546 | """ |
| 547 | run ModuleProcessor for each modules |
| 548 | |
| 549 | :param configuration: user final configuration |
| 550 | :return: |
| 551 | """ |
| 552 | for module in configuration: |
| 553 | module_processor_thread = Thread( |
| 554 | target=configuration[module]["module_processor"].processor, |
| 555 | name=virtual_machine_name_to_container_name( |
| 556 | configuration[module]["virtual_machine_name"], |
| 557 | module |
| 558 | ) |
| 559 | ) |
| 560 | module_processor_thread.start() |
| 561 | processor_threads.append(module_processor_thread) |
| 562 | return |
| 563 | |
| 564 | |
| 565 | def stop_modules_processors(configuration): |
no test coverage detected