diff --git a/myreco/engine_objects/data_importer/model.py b/myreco/engine_objects/data_importer/model.py index e88133d..3e7a779 100644 --- a/myreco/engine_objects/data_importer/model.py +++ b/myreco/engine_objects/data_importer/model.py @@ -70,7 +70,7 @@ def _get_jobs_id(cls, engine_object): @classmethod def _run_import_data_job(cls, req, session, engine_object): items_model = cls._get_items_model(engine_object) - engine_object = cls._get_engine_object_instance(engine_object) + engine_object = cls.get_engine_object_instance(engine_object) return engine_object.get_data( items_model, session @@ -84,7 +84,7 @@ def _get_items_model(cls, engine_object): ) @classmethod - def _get_engine_object_instance(cls, engine_object): + def get_engine_object_instance(cls, engine_object): strategy_class = engine_object.strategy.get_class() object_class = strategy_class.object_types[engine_object.type] return object_class(engine_object.todict(), cls.__data_path__) diff --git a/myreco/engine_objects/exporter/model.py b/myreco/engine_objects/exporter/model.py index dcddf80..66cabb0 100644 --- a/myreco/engine_objects/exporter/model.py +++ b/myreco/engine_objects/exporter/model.py @@ -52,7 +52,7 @@ def _get_jobs_id_exporter(cls, engine_object): def _run_export_objects_job(cls, req, session, engine_object): import_data = req.query.get('import_data') items_model = cls._get_items_model(engine_object) - engine_object = cls._get_engine_object_instance(engine_object) + engine_object = cls.get_engine_object_instance(engine_object) if import_data: importer_result = engine_object.get_data(items_model, session) diff --git a/myreco/item_types/filters_updater/model.py b/myreco/item_types/filters_updater/model.py index 86c9c5b..6dedf72 100644 --- a/myreco/item_types/filters_updater/model.py +++ b/myreco/item_types/filters_updater/model.py @@ -42,14 +42,14 @@ async def post_update_filters_job(cls, req, session): async def _run_update_filters_job(cls, req, session, store_items_model, store_id, **kwargs): cls._logger.info("Started update filters for '{}'".format(store_items_model.__key__)) - return await cls._update_enabled_filters(store_items_model, session, store_id) + return await cls.update_enabled_filters(store_items_model, session, store_id) @classmethod async def get_update_filters_job(cls, req, session): return await cls._get_job('_updater', req, session) @classmethod - async def _update_enabled_filters(cls, store_items_model, session, store_id): + async def update_enabled_filters(cls, store_items_model, session, store_id): items_indices_map = store_items_model.indices_map items_indices_map_ret = await items_indices_map.update(session) items_indices_map_len = await items_indices_map.get_length(session) diff --git a/version.py b/version.py index bf3d3fe..e351dc9 100644 --- a/version.py +++ b/version.py @@ -21,4 +21,4 @@ # SOFTWARE. -VERSION = '0.59.0' +VERSION = '0.60.0'