ethos_penalps.post_processing.enterprise_graph_for_failed_run

Module Contents

Classes

GraphVizTableCreator
GraphVisualization

Attributes

logger

ethos_penalps.post_processing.enterprise_graph_for_failed_run.logger

class ethos_penalps.post_processing.enterprise_graph_for_failed_run.GraphVizTableCreator

add_row(list_of_columns: list[str])

create_table_node(graph: graphviz.Digraph, table_name: str)

add_first_row(list_of_columns: list[str])

class ethos_penalps.post_processing.enterprise_graph_for_failed_run.GraphVisualization(process_node_dict: dict[str, ethos_penalps.process_nodes.process_node.ProcessNode], stream_handler: ethos_penalps.stream_handler.StreamHandler, graph_name: str = 'Graph', output_file_extension: str = 'svg', enterprise_name='Enterprise')

create_process_step_node_cluster(enterprise_cluster: graphviz.graphs.Digraph, process_step: ethos_penalps.process_nodes.process_step.ProcessStep, color='black')

create_source_node(enterprise_cluster: graphviz.graphs.Digraph, source: ethos_penalps.process_nodes.source.Source | ethos_penalps.process_nodes.process_chain_storage.ProcessChainStorage, color: str)

create_sink_node(enterprise_cluster: graphviz.graphs.Digraph, sink: ethos_penalps.process_nodes.sink.Sink | ethos_penalps.process_nodes.process_chain_storage.ProcessChainStorage, color: str)

add_stream(stream: ethos_penalps.stream.ContinuousStream | ethos_penalps.stream.BatchStream, edge_colour: str = 'black')

create_enterprise_structure_graph(show_graph_after_creation: bool = True, stream_state_table_creator: GraphVizTableCreator | None = None, node_operation_table_creator: GraphVizTableCreator | None = None, production_order_table_creator: GraphVizTableCreator | None = None, starting_node_output_branch_data_table_creator: GraphVizTableCreator | None = None, current_node_operation_name: str | None = None, active_stream_name: str | None = None, graph_directory: str | None = None, file_name: str | None = None)