ethos_penalps.process_nodes.source#

Module Contents#

Classes#

Source

Attributes#

logger

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

Bases: ethos_penalps.process_nodes.process_node.ProcessNode

__str__() str#
add_output_stream(output_stream: ethos_penalps.stream.ContinuousStream | ethos_penalps.stream.BatchStream, process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier)#
create_storage_entries()#
set_current_output_stream(process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier)#
prepare_source_for_next_chain(process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier)#
get_downstream_node_name() str#
create_complete_branch_data(upstream_new_production_order: ethos_penalps.node_operations.UpstreamNewProductionOrder) ethos_penalps.simulation_data.simulation_data_branch.CompleteOutputBranchData#
process_input_order(input_node_operation: ethos_penalps.node_operations.NodeOperation) ethos_penalps.node_operations.DownstreamValidationOrder#
create_production_order_collection_from_input_states() ethos_penalps.data_classes.OrderCollection#
create_downstream_validation_operation(upstream_new_production_order: ethos_penalps.node_operations.UpstreamNewProductionOrder) ethos_penalps.node_operations.DownstreamValidationOrder#
get_input_stream_name() None#
get_output_stream_name() str#