Skip to content
Snippets Groups Projects
Commit 3de4a123 authored by thomaswoehlke's avatar thomaswoehlke
Browse files

Refactoring: vaccination

parent c7288bad
No related branches found
No related tags found
1 merge request!162Refactoring 2021 05 20 start
...@@ -16,7 +16,7 @@ class AllDataServiceDispachterMatrix: ...@@ -16,7 +16,7 @@ class AllDataServiceDispachterMatrix:
app.logger.debug("------------------------------------------------------------") app.logger.debug("------------------------------------------------------------")
self.__services_for = { self.__services_for = {
'download': [ 'download': [
who_service, owid_service, rki_service, vaccination_service, ecdc_service, divi_service who_service, vaccination_service, divi_service, ecdc_service, owid_service, rki_service
], ],
'import_file': [ 'import_file': [
who_service, vaccination_service, ecdc_service, owid_service, rki_service who_service, vaccination_service, ecdc_service, owid_service, rki_service
...@@ -38,6 +38,12 @@ class AllDataServiceDispachterMatrix: ...@@ -38,6 +38,12 @@ class AllDataServiceDispachterMatrix:
], ],
'update_star_schema': [ 'update_star_schema': [
who_service, vaccination_service, ecdc_service, owid_service, rki_service who_service, vaccination_service, ecdc_service, owid_service, rki_service
],
'full_update': [
who_service, vaccination_service, ecdc_service, owid_service, rki_service
],
'update': [
who_service, vaccination_service, ecdc_service, owid_service, rki_service
] ]
} }
app.logger.debug("------------------------------------------------------------") app.logger.debug("------------------------------------------------------------")
...@@ -135,8 +141,8 @@ class AllDataServiceDispachterMatrix: ...@@ -135,8 +141,8 @@ class AllDataServiceDispachterMatrix:
app.logger.info(" ") app.logger.info(" ")
app.logger.info(" AllDataServiceDispachterMatrix.full_update [start] ") app.logger.info(" AllDataServiceDispachterMatrix.full_update [start] ")
app.logger.info(" ") app.logger.info(" ")
self.import_file() for service in self.__services_for['full_update']:
self.full_update_star_schema() service.full_update()
app.logger.info(" ") app.logger.info(" ")
app.logger.info(" AllDataServiceDispachterMatrix.full_update [done] ") app.logger.info(" AllDataServiceDispachterMatrix.full_update [done] ")
app.logger.info(" ") app.logger.info(" ")
...@@ -146,8 +152,8 @@ class AllDataServiceDispachterMatrix: ...@@ -146,8 +152,8 @@ class AllDataServiceDispachterMatrix:
app.logger.info(" ") app.logger.info(" ")
app.logger.info(" AllDataServiceDispachterMatrix.update [start] ") app.logger.info(" AllDataServiceDispachterMatrix.update [start] ")
app.logger.info(" ") app.logger.info(" ")
self.import_file() for service in self.__services_for['update']:
self.update_star_schema() service.update()
app.logger.info(" ") app.logger.info(" ")
app.logger.info(" AllDataServiceDispachterMatrix.update [done] ") app.logger.info(" AllDataServiceDispachterMatrix.update [done] ")
app.logger.info(" ") app.logger.info(" ")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment