pipert.core.pipeline_manager

Module Contents

Functions

component_name_existence_error(need_to_be_exist)

pipert.core.pipeline_manager.component_name_existence_error(need_to_be_exist)[source]
class pipert.core.pipeline_manager.PipelineManager[source]
add_routine_to_component(self, component_name, routine_type_name, **routine_parameters_kwargs)[source]
remove_routine_from_component(self, component_name, routine_name)[source]
create_queue_to_component(self, component_name, queue_name, queue_size=1)[source]
remove_queue_from_component(self, component_name, queue_name)[source]
run_component(self, component_name)[source]
stop_component(self, component_name)[source]
run_all_components(self)[source]
stop_all_components(self)[source]
get_all_routine_types(self)[source]
change_component_execution_mode(self, component_name, execution_mode)[source]
static _remove_string_with_underscore(match)[source]
static _add_underscore_before_uppercase(match)[source]
get_routine_parameters(self, routine_type_name)[source]
setup_components(self, components)[source]

vvv Expecting to get vvv “components”: {

“component_name”: {

“queues”: [str], “routines”: {

“routine_name”: {

“routine_type_name”: str, …(routine params)

}, …(more routines)

}

} …(more components)

}

_get_routine_class_object_by_type_name(self, routine_name: str) → Optional[Routine][source]
_does_component_exist(self, component_name)[source]
_is_component_running(self, component_name)[source]
static _create_response(succeeded, message)[source]
get_pipeline_creation(self)[source]
get_random_available_port(self)[source]
set_routine_parameter_in_component(self, component_name, routine_name, attribute_name, attribute_value)[source]