finam.adapters.DelayFixed#

class finam.adapters.DelayFixed(delay)[source]#

Bases: TimeDelayAdapter

Delays/offsets the request time by subtracting a fixed offset.

Delayed times that are located before the initial pull/request time are set to this time.

An illustrative example: Component A has a step of 10 days. The adapter has a delay of 11 days to guarantee data availability in B.

A  O=========O---------o
^           .<---------'
|           V
B  =O=O=O=O=O
Parameters:

delay (datetime.timedelta) – The delay duration to subtract from the request time.

See also

adapters.DelayToPull

Delays to use data from a previous pull.

adapters.DelayToPush

Delays to use data from the last push.

Attributes:
has_source

Flag if this input instance has a source.

has_targets

Flag if this output instance has any targets.

info

Info: The input’s data info.

is_static

Whether the input is static

logger

Logger for this component.

logger_name

Logger name derived from source logger name and class name.

memory_limit

The memory limit for this slot

memory_location

The memory-mapping location for this slot

metadata

The adapter’s metadata.

name

Input name.

needs_pull

bool: if the adapter needs pull.

needs_push

bool: if the adapter needs push.

source

Get the input’s source output or adapter

targets

Get target inputs and adapters for this output.

time

The output’s time of the latest available data

uses_base_logger_name

Whether this class has a base_logger_name attribute.

Methods

add_target(target)

Add a target input or adapter for this output.

chain(other)

Chain outputs and adapters.

exchange_info([info])

Exchange the data info with the input's source.

finalize()

Called at the end of each run.

get_data(time, target)

Get the transformed data of this adapter.

get_info(info)

Exchange and get the output's data info.

has_info()

Returns if the output has a data info.

notify_targets(time)

Notify all targets by calling their source_updated(time) method.

ping()

Pings upstream to inform outputs about the number of connected inputs.

pinged(source)

Called when receiving a ping from a downstream input.

pull_data(time[, target])

Retrieve the data from the input's source.

push_data(data, time)

Push data into the output.

push_info(info)

Push data info into the output.

source_updated(time)

Informs the input that a new output is available.

with_delay(time)

Get the manipulated time for a given request time.

with_name(name)

Renames the adapter and returns self.

with_delay(time)[source]#

Get the manipulated time for a given request time.

Parameters:

time (datetime) – The original request time.

Returns:

The time as manipulated by the adapter

Return type:

datetime

_finalize()#

Called at the end of each run. Overwrite this for cleanup.

_get_data(time, target)#

Get the output’s data-set for the given time.

Parameters:

time (datetime) – simulation time to get the data for.

Returns:

data-set for the requested time.

Return type:

array_like

_get_info(info)#

Exchange and get the output’s data info.

Adapters can overwrite this method to manipulate the metadata for the output.

Parameters:

info (Info) – Requested data info

Returns:

Delivered data info

Return type:

Info

_pulled(time)#

This method is called during pulls, with the original pull time.

Can be overwritten to store the original pull time, as in _get_data() only the manipulated time is available.

Called after _get_data() (i.e. after the actual pull).

Parameters:

time (datetime) – The original (requested) time of the current pull.

_source_updated(time)#

Informs the input that a new output is available.

Adapters can overwrite this method to handle incoming data.

Adapters that make use of this method to accumulate data should also overwrite needs_push to return True.

Parameters:

time (datetime) – Simulation time of the notification.

add_target(target)#

Add a target input or adapter for this output.

Parameters:

target (IInput) – The target to add.

chain(other)#

Chain outputs and adapters.

Parameters:

other (IInput or IAdapter) – The adapter or input to add as target to this output.

Returns:

The last element of the chain.

Return type:

IOutput

exchange_info(info=None)#

Exchange the data info with the input’s source.

Parameters:

info (Info) – request parameters

Returns:

delivered parameters

Return type:

Info

finalize()#

Called at the end of each run. Calls _finalize().

get_data(time, target)#

Get the transformed data of this adapter.

Internally calls _get_data().

Parameters:
  • time (datetime) – Simulation time to get the data for.

  • target (IInput) – Requesting end point of this pull.

Returns:

Transformed data-set for the requested time.

Return type:

pint.Quantity

get_info(info)#

Exchange and get the output’s data info.

Parameters:

info (Info) – Requested data info

Returns:

Delivered data info

Return type:

dict

Raises:

FinamNoDataError – Raises the error if no info is available

has_info()#

Returns if the output has a data info.

The info is not required to be validly exchanged.

property has_source#

Flag if this input instance has a source.

property has_targets#

Flag if this output instance has any targets.

property info#

The input’s data info.

Type:

Info

property is_static#

Whether the input is static

property logger#

Logger for this component.

property logger_name#

Logger name derived from source logger name and class name.

property memory_limit#

The memory limit for this slot

property memory_location#

The memory-mapping location for this slot

property metadata#

The adapter’s metadata. Will only be called after the connect phase from Composition.metadata.

Adapters can overwrite this property to add their own specific metadata:

import finam as fm

class MyAdapter(fm.Adapter):

    @property
    def metadata(self):
        # Get the default metadata
        md = super().metadata

        # Add your own metadata
        md["my_field"] = "some value"

        # Return the dictionary
        return md
Returns:

A dict with the following default metadata:
  • name - the component’s name

  • class - the component’s class

Return type:

dict

property name#

Input name.

property needs_pull#

if the adapter needs pull.

Type:

bool

property needs_push#

if the adapter needs push.

Type:

bool

notify_targets(time)#

Notify all targets by calling their source_updated(time) method.

Parameters:

time (datetime) – Simulation time of the simulation.

ping()#

Pings upstream to inform outputs about the number of connected inputs.

Must be called after linking and before the connect phase.

pinged(source)#

Called when receiving a ping from a downstream input.

pull_data(time, target=None)#

Retrieve the data from the input’s source.

Parameters:
  • time (datetime) – Simulation time to get the data for.

  • target (IInput or None) – Requesting end point of this pull. Should be None for normal input pulls in components. Simple adapters should forward the source in Adapter._get_data(). Push-based adapters should use self in Adapter._source_updated().

Returns:

Data set for the given simulation time.

Return type:

pint.Quantity

push_data(data, time)#

Push data into the output.

Should notify targets, and can handle the provided date.

Parameters:
  • data (array_like) – Data set to push.

  • time (datetime) – Simulation time of the data set.

push_info(info)#

Push data info into the output.

Parameters:

info (Info) – Delivered data info

property source#

Get the input’s source output or adapter

Returns:

The input’s source.

Return type:

IOutput

source_updated(time)#

Informs the input that a new output is available.

Parameters:

time (datetime) – Simulation time of the notification.

property targets#

Get target inputs and adapters for this output.

Returns:

List of targets.

Return type:

list

property time#

The output’s time of the latest available data

property uses_base_logger_name#

Whether this class has a base_logger_name attribute. True.

with_name(name)#

Renames the adapter and returns self.