Skip to content

Commit

Permalink
updated some methods from private to public
Browse files Browse the repository at this point in the history
  • Loading branch information
dutradda committed Jul 25, 2017
1 parent 8067a61 commit 501649b
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions myreco/engine_objects/data_importer/model.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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__)
Expand Down
2 changes: 1 addition & 1 deletion myreco/engine_objects/exporter/model.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
4 changes: 2 additions & 2 deletions myreco/item_types/filters_updater/model.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
2 changes: 1 addition & 1 deletion version.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,4 +21,4 @@
# SOFTWARE.


VERSION = '0.59.0'
VERSION = '0.60.0'

0 comments on commit 501649b

Please sign in to comment.