Skip to main content
def DataLoaderWorker.fit(self, inputs, fx_choice=REG.AIG, **params) [source]
Execute the full data ingestion and standardization pipeline. Ingests data from the configured source, verifies constraints, standardizes the format, and performs the time-based train/test split.

​
Parameters

inputs : DataLoaderInput
Flow context configuration (resolved from ctx.setup).
 fx_choice : str
The fitting strategy identifier. Defaults to REG.AIG.
 **params : dict
Runtime parameters passed to the internal fitter
(import_start, import_end, train_test, smp_learn, smp_feature).

​
Returns

DataLoader
The fitted instance with train/test split and
variable type classification available.