Update multiprocessing_in_date_ingestion.py

multiprocessing_in_date_ingestion.py

@@ -77,12 +77,12 @@ def process_biomarker_detail(args):
     for attribute in attributes:
         attribute_details = attribute['attribute_details']
         attribute['attribute_details'], logging_df = report_date_insertion(attribute_details, df_list, logging_df)
-    return biomarker_detail
+    return biomarker_detail, logging_df
 
 def json_report_date_insertion(json_data, df_list, logging_df):
     biomarker_details = json_data['patient_level']['biomarkers']['details']
     with Pool() as pool:
-        updated_biomarker_details = pool.map(process_biomarker_detail, [(biomarker_detail, df_list, logging_df) for biomarker_detail in biomarker_details])
+        results = pool.map(process_biomarker_detail, [(biomarker_detail, df_list, logging_df) for biomarker_detail in biomarker_details])
+    updated_biomarker_details, updated_logging_df = zip(*results)
     json_data['patient_level']['biomarkers']['details'] = updated_biomarker_details
-    return json_data, logging_df
-
+    return json_data, updated_logging_df