ethos_penalps.process_nodes.sink

Module Contents

Classes

Sink	Is end point of the process node chain.

Attributes

logger

ethos_penalps.process_nodes.sink.logger

class ethos_penalps.process_nodes.sink.Sink(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, order_collection: ethos_penalps.data_classes.OrderCollection | None = None)

Bases: ethos_penalps.process_nodes.process_node.ProcessNode

Is end point of the process node chain.

Parameters:

ProcessNode (_type_) – _description_

__str__() → str

check_if_sink_has_orders()

plan_production() → ethos_penalps.node_operations.UpstreamNewProductionOrder

Creates the initial Upstream production order by.

Returns:

_description_

Return type:

_type_

convert_order_to_stream(production_order: ethos_penalps.node_operations.ProductionOrder) → ethos_penalps.stream.ContinuousStreamState | ethos_penalps.stream.BatchStreamState

create_storage_entries(list_of_output_stream_states: list[ethos_penalps.stream.ContinuousStreamState | ethos_penalps.stream.BatchStreamState] | None = None)

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.UpstreamAdaptionOrder | ethos_penalps.node_operations.TerminateProduction

Decides if another upstream production operation is required of is the production is terminated

Parameters:

node_operation (NodeOperation) – _description_

Returns:

_description_

Return type:

UpstreamNewProductionOrder

update_production_order(validated_input_stream_state: ethos_penalps.stream.ContinuousStreamState | ethos_penalps.stream.BatchStreamState)

store_input_streams_to_production_plan()

create_upstream_adaption_operation(downstream_adaption_operation: ethos_penalps.node_operations.DownstreamAdaptionOrder) → ethos_penalps.node_operations.UpstreamAdaptionOrder

create_upstream_new_production_operation(input_stream_state: ethos_penalps.stream.ContinuousStreamState | ethos_penalps.stream.BatchStreamState, production_order: ethos_penalps.node_operations.ProductionOrder) → ethos_penalps.node_operations.UpstreamNewProductionOrder

create_branch_data()

create_new_production_branch_identifier() → ethos_penalps.data_classes.OutputBranchIdentifier

create_new_temporal_branch_identifier() → ethos_penalps.data_classes.TemporalBranchIdentifier

add_input_stream(input_stream: ethos_penalps.stream.ContinuousStream | ethos_penalps.stream.BatchStream, process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier)

get_upstream_node_name() → str

get_input_stream_name() → str

create_load_profile_entry(stream_entry)

get_order_from_parent_source(order_collection_from_source: ethos_penalps.data_classes.OrderCollection)

initialize_sink()

prepare_sink_for_next_chain(process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier)

get_stream_to_process_chain(process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier) → ethos_penalps.stream.BatchStream | ethos_penalps.stream.ContinuousStream

get_output_stream_name() → None