diff --git a/src/flask_covid19/blueprints/data_owid/owid_service.py b/src/flask_covid19/blueprints/data_owid/owid_service.py index f80b353947adc2800668ce09bc6bd921468bfd3d..e236e00688aa4bf4118c075eb704134d4351d0e1 100644 --- a/src/flask_covid19/blueprints/data_owid/owid_service.py +++ b/src/flask_covid19/blueprints/data_owid/owid_service.py @@ -50,11 +50,19 @@ class OwidService: return self def full_update_star_schema(self): - self.service_import.import_file() self.service_update_full.full_update_star_schema() return self def update_star_schema(self): + self.service_update.update_star_schema() + return self + + def full_update(self): + self.service_import.import_file() + self.service_update_full.full_update_star_schema() + return self + + def update(self): self.service_import.import_file() self.service_update.update_star_schema() - return self \ No newline at end of file + return self diff --git a/src/flask_covid19/blueprints/data_owid/owid_views.py b/src/flask_covid19/blueprints/data_owid/owid_views.py index ff8edd93ab6d4ce24dd50b229641b0dd81df4e1d..a8735e0c7f9c81899ddccc7a721675f1527742e8 100644 --- a/src/flask_covid19/blueprints/data_owid/owid_views.py +++ b/src/flask_covid19/blueprints/data_owid/owid_views.py @@ -397,6 +397,7 @@ def task_owid_update_star_schema(self): return result +@celery.task(bind=True) def task_owid_full_update(self): logger = get_task_logger(__name__) self.update_state(state=states.STARTED)