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.
- _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.
- _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 returnTrue
.- 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.
- exchange_info(info=None)#
Exchange the data info with the input’s source.
- 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:
- Returns:
Transformed data-set for the requested time.
- Return type:
- get_info(info)#
Exchange and get the output’s data info.
- Parameters:
info (
Info
) – Requested data info- Returns:
Delivered data info
- Return type:
- 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 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 nameclass
- the component’s class
- A
- Return type:
- property name#
Input name.
- 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 beNone
for normal input pulls in components. Simple adapters should forward the source inAdapter._get_data()
. Push-based adapters should useself
inAdapter._source_updated()
.
- Returns:
Data set for the given simulation time.
- Return type:
- 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.
- property source#
Get the input’s source output or adapter
- Returns:
The input’s source.
- Return type:
- 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:
- 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.