Merge branch 'hotfix/3685_file_handlers_fix'

DOAJ · Aug 21, 2023 · 23b21c3 · 23b21c3
2 parents 180432e + 627d74e
commit 23b21c3
Showing 1 changed file with 16 additions and 5 deletions.
diff --git a/portality/scripts/applications_rejected_data.py b/portality/scripts/applications_rejected_data.py
@@ -8,6 +8,8 @@
 
 APP_FILE_HANDLES = {}
 UR_FILE_HANDLES = {}
+APP_WRITERS = {}
+UR_WRITERS = {}
 APP_RECORD_COUNTER = {}
 UR_RECORD_COUNTER = {}
 BASE_DIR_PATH = None
@@ -71,14 +73,23 @@ def provenance_query(resource_id):
 def get_file_handler(year, application_type):
     global APP_FILE_HANDLES
     global UR_FILE_HANDLES
+    global APP_WRITERS
+    global UR_WRITERS
     # applications file handle
     if application_type == constants.APPLICATION_TYPE_NEW_APPLICATION:
-        filename = os.path.join(BASE_DIR_PATH, "rejected_applications_" + str(year) + ".csv")
-        return csv.writer(APP_FILE_HANDLES.setdefault(year, open(filename, 'w')))
-    # update requests file handle
+        if year not in APP_WRITERS:
+            filename = os.path.join(BASE_DIR_PATH, "rejected_applications_" + str(year) + ".csv")
+            file_handle = open(filename, 'w')
+            APP_FILE_HANDLES[year] = file_handle
+            APP_WRITERS[year] = csv.writer(file_handle)
+        return APP_WRITERS[year]
     else:
-        filename = os.path.join(BASE_DIR_PATH, "rejected_update_requests_" + str(year) + ".csv")
-        return csv.writer(UR_FILE_HANDLES.setdefault(year, open(filename, 'w')))
+        if year not in UR_WRITERS:
+            filename = os.path.join(BASE_DIR_PATH, "rejected_update_requests_" + str(year) + ".csv")
+            file_handle = open(filename, 'w')
+            UR_FILE_HANDLES[year] = file_handle
+            UR_WRITERS[year] = csv.writer(file_handle)
+        return UR_WRITERS[year]
 
 
 def get_record_counter(year, application_type):