Merge pull request #381 from OP-TED/hotfix/TED-1016

Hotfix/ted 1016

Author: CaptainOfHacks

ted_sws/data_manager/adapters/notice_repository.py

@@ -130,12 +130,12 @@ def __init__(self, mongodb_client: MongoClient, database_name: str = None):
         self._database_name = database_name
         self.mongodb_client = mongodb_client
         notice_db = mongodb_client[self._database_name]
-        self.file_storage = gridfs.GridFS(notice_db)
+        self.file_storage = gridfs.GridFS(notice_db) # TODO: Investigate how it works in multiple processes in parallel.
         self.collection = notice_db[self._collection_name]
-        self.collection.create_index([(NOTICE_CREATED_AT, ASCENDING)])
-        self.collection.create_index([(NOTICE_STATUS, ASCENDING)])
+        self.collection.create_index([(NOTICE_CREATED_AT, ASCENDING)]) # TODO: index creation may bring race condition error.
+        self.collection.create_index([(NOTICE_STATUS, ASCENDING)]) # TODO: index creation may bring race condition error.
         self.file_storage_collection = notice_db[FILE_STORAGE_COLLECTION_NAME]
-        self.file_storage_collection.create_index([(NOTICE_ID, ASCENDING)])
+        self.file_storage_collection.create_index([(NOTICE_ID, ASCENDING)]) # TODO: index creation may bring race condition error.
 
     def get_file_content_from_grid_fs(self, file_id: str) -> str:
         """

ted_sws/data_manager/adapters/supra_notice_repository.py

@@ -22,7 +22,7 @@ def __init__(self, mongodb_client: MongoClient, database_name: str = None):
         self.mongodb_client = mongodb_client
         daily_supra_notice_db = mongodb_client[self._database_name]
         self.collection = daily_supra_notice_db[self._collection_name]
-        self.collection.create_index([(DAILY_SUPRA_NOTICE_ID, ASCENDING)])
+        self.collection.create_index([(DAILY_SUPRA_NOTICE_ID, ASCENDING)]) # TODO: index creation may bring race condition error.
 
     def _update_daily_supra_notice(self, daily_supra_notice: DailySupraNotice, upsert: bool = False):
         daily_supra_notice_dict = daily_supra_notice.dict()

ted_sws/event_manager/adapters/event_logging_repository.py

@@ -58,10 +58,13 @@ def create_indexes(self):
 
         :return: None
         """
-        self.collection.create_index([("year", DESCENDING)])
-        self.collection.create_index([("month", ASCENDING)])
-        self.collection.create_index([("day", ASCENDING)])
-        self.collection.create_index([("caller_name", ASCENDING)])
+        try: # FIXME: This is temporary solution for exclude race condition error
+            self.collection.create_index([("year", DESCENDING)]) # TODO: index creation may bring race condition error.
+            self.collection.create_index([("month", ASCENDING)]) # TODO: index creation may bring race condition error.
+            self.collection.create_index([("day", ASCENDING)]) # TODO: index creation may bring race condition error.
+            self.collection.create_index([("caller_name", ASCENDING)]) # TODO: index creation may bring race condition error.
+        except:
+            pass
 
     @classmethod
     def prepare_record(cls, event_message: EventMessage) -> dict: