Skip to content

Commit

Permalink
examples refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
v1docq committed Apr 12, 2024
1 parent 44ee34f commit f962d6f
Show file tree
Hide file tree
Showing 19 changed files with 8 additions and 145 deletions.
Empty file.
Empty file.
Empty file.
Empty file.
File renamed without changes.

This file was deleted.

This file was deleted.

3 changes: 2 additions & 1 deletion fedot_ind/api/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -169,7 +169,8 @@ def fit(self,
self.__init_solver()
if self.industrial_strategy is not None:
self.solver = self.industrial_strategy_class.fit(self.train_data)
self.solver.fit(self.train_data)
else:
self.solver.fit(self.train_data)

def predict(self,
predict_data: tuple,
Expand Down
3 changes: 3 additions & 0 deletions fedot_ind/api/utils/checkers_collections.py
Original file line number Diff line number Diff line change
Expand Up @@ -92,8 +92,11 @@ def _init_input_data(self) -> None:
features_array = np.array(self.input_data.values)
task = Task(TaskTypesEnum.ts_forecasting,
TsForecastingParams(forecast_length=self.task_params['forecast_length']))
features_array = features_array[:-self.task_params['forecast_length']]
target = features_array[-self.task_params['forecast_length']:]
self.input_data = InputData.from_numpy_time_series(
features_array=features_array,
target_array=target,
task=task)
else:
self.input_data = InputData(idx=np.arange(len(X)),
Expand Down
7 changes: 3 additions & 4 deletions fedot_ind/api/utils/industrial_strategy.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,8 +33,8 @@ def fit(self, input_data):
self.industrial_strategy_fit[self.industrial_strategy](input_data)
return self.solver

def predict(self, input_data):
return self.industrial_strategy_predict[self.industrial_strategy](input_data)
def predict(self, input_data, predict_mode):
return self.industrial_strategy_predict[self.industrial_strategy](input_data, predict_mode)

def _federated_strategy(self, input_data):
if input_data.features.shape[0] > BATCH_SIZE_FOR_FEDOT_WORKER:
Expand All @@ -53,10 +53,9 @@ def _finetune_loop(self,
kernel_data: dict,
tuning_params: dict = {}):
tuned_kernels = {}
tuned_metric = 0
tuning_params['metric'] = FEDOT_TUNING_METRICS[self.config_dict['problem']]

for generator, kernel_model in kernel_ensemble.items():
tuned_metric = 0
for tuner_name, tuner_type in FEDOT_TUNER_STRATEGY.items():
tuning_params['tuner'] = tuner_type
model_to_tune = deepcopy(kernel_model)
Expand Down

0 comments on commit f962d6f

Please sign in to comment.