diff --git a/drugstone/__init__.py b/drugstone/__init__.py index b4ad9c7fdcdbea622d779b87e466d7dfa29e357b..1c051f59447c4640f82d9a02eb6f44d050a64c45 100755 --- a/drugstone/__init__.py +++ b/drugstone/__init__.py @@ -3,4 +3,4 @@ from drugstone.wsgi import application # noqa: F401 # Django starts so that shared_task will use this app. from drugstone.celery import app as celery_app -__all__ = ['celery_app'] \ No newline at end of file +__all__ = ['celery_app'] diff --git a/drugstone/settings/__init__.py b/drugstone/settings/__init__.py index c70020d5f7b2fe8c5d7f62e339f4c79895986c8f..7d7765a772514b84fe01819a59cb6bf9c6953ae8 100644 --- a/drugstone/settings/__init__.py +++ b/drugstone/settings/__init__.py @@ -1 +1 @@ -from .settings import * \ No newline at end of file +from .settings import * diff --git a/drugstone/settings/celery_schedule.py b/drugstone/settings/celery_schedule.py index 88e8f9aee8e6d6192e8ed3bf142da9de508a5ba2..f817c9511f74e046c65995a5add04516a884b51e 100644 --- a/drugstone/settings/celery_schedule.py +++ b/drugstone/settings/celery_schedule.py @@ -5,4 +5,4 @@ CELERY_BEAT_SCHEDULE = { "task": "drugstone.tasks.task_update_db_from_nedrex", "schedule": crontab(minute="*/1000"), }, -} \ No newline at end of file +} diff --git a/drugstone/tasks.py b/drugstone/tasks.py index 4547ea4f97d3ffc9ccb3b168e3c1c65ba7ecc94b..c52aaf70056dc9e373088368f72b41749c6c7460 100644 --- a/drugstone/tasks.py +++ b/drugstone/tasks.py @@ -4,15 +4,15 @@ from drugstone.util.nedrex import fetch_nedrex_data, integrate_nedrex_data logger = get_task_logger(__name__) + @shared_task def task_update_db_from_nedrex(): logger.info("Updating DB from NeDRex.") print('here') - + logger.info("Fetching data...") fetch_nedrex_data() logger.info("Integrating data...") integrate_nedrex_data() logger.info("Done.") - diff --git a/drugstone/util/nedrex.py b/drugstone/util/nedrex.py index 01051962d6312e56809fdbc74d43cd6180ddfed6..d3f85eb65900916f724c433d616a7035138026a4 100644 --- a/drugstone/util/nedrex.py +++ b/drugstone/util/nedrex.py @@ -2,6 +2,7 @@ def fetch_nedrex_data(): print('fetching') return + def integrate_nedrex_data(): print('integrating') - return \ No newline at end of file + return