Process (Core)#

alts.core.data_process.process

class Process(time_source, data_pools, oracles)[source]#

Description

The Process is the module responsible for processing the Estimator’s queries and providing their results as well as saving all the queried data.

Parameters:

time_source (TimeSource) – Source of time
data_pools (DataPools) – A data structure which saves all processed queries and results
oracles (Oracles) – The interaction point between the Process and the data source.

data_pools: DataPools = Field(name=None,type=None,default=<dataclasses._MISSING_TYPE object>,default_factory=<dataclasses._MISSING_TYPE object>,init=False,repr=False,hash=None,compare=True,metadata=mappingproxy({}),_field_type=None)#

initialize(self) → None[source]#: Description

Does everything that needs to be done for the Process to be ready.

last_queries: NDArray[Shape["data_nr, ... query_shape"], Number] = post_init()#

last_results: NDArray[Shape["data_nr, ... result_shape"], Number] = post_init()#

oracles: Oracles = Field(name=None,type=None,default=<dataclasses._MISSING_TYPE object>,default_factory=<dataclasses._MISSING_TYPE object>,init=False,repr=False,hash=None,compare=True,metadata=mappingproxy({}),_field_type=None)#

step(self, iteration)[source]#

Description

Advances the time (of its time source) by iteration step and returns the new data.

Parameters:

iteration (int) – Amount of steps to do

Returns:

Processed Queries before step, Results before step, Processed Queries after step, Results after step

Return type:

NDArray, NDArray, NDArray, NDArray

time_source: TimeSource = Field(name=None,type=None,default=<dataclasses._MISSING_TYPE object>,default_factory=<dataclasses._MISSING_TYPE object>,init=False,repr=False,hash=None,compare=True,metadata=mappingproxy({}),_field_type=None)#

Process (Core)