Ctrl+K

ethos_penalps.process_nodes.process_chain_storage

ethos_penalps.process_nodes.process_chain_storage#

Module Contents#

Classes#

ProcessChainStorage

class ethos_penalps.process_nodes.process_chain_storage.ProcessChainStorage(name: str, commodity: ethos_penalps.data_classes.Commodity, stream_handler: ethos_penalps.stream_handler.StreamHandler, production_plan: ethos_penalps.production_plan.ProductionPlan, time_data: ethos_penalps.time_data.TimeData)#

Bases: ethos_penalps.process_nodes.process_node.ProcessNode

add_sink_from_next_network_level(name: str, commodity: ethos_penalps.data_classes.Commodity, stream_handler: ethos_penalps.stream_handler.StreamHandler, production_plan: ethos_penalps.production_plan.ProductionPlan, time_data: ethos_penalps.time_data.TimeData)#
switch_from_source_to_sink()#
create_storage_entries()#
process_input_order(input_node_operation: ethos_penalps.node_operations.DownstreamAdaptionOrder | ethos_penalps.node_operations.DownstreamValidationOrder | ethos_penalps.node_operations.UpstreamNewProductionOrder | ethos_penalps.node_operations.TerminateProduction)#
add_output_stream(output_stream: ethos_penalps.stream.ContinuousStream | ethos_penalps.stream.BatchStream, process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier)#
add_input_stream(input_stream: ethos_penalps.stream.ContinuousStream | ethos_penalps.stream.BatchStream, process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier)#
initialize_sink()#
get_input_stream_name() → str#
get_output_stream_name() → str#
prepare_sink_for_next_chain(process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier)#
prepare_source_for_next_chain(process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier)#
check_if_sink_has_orders()#
plan_production() → ethos_penalps.node_operations.UpstreamNewProductionOrder#
get_upstream_node_name() → str#
get_downstream_node_name() → str#
Contents