Update multiprocessing_in_date_ingestion.py

multiprocessing_in_date_ingestion.py

@@ -71,7 +71,8 @@ def report_date_insertion(dict_list, df_list, logging_df):
 
     return dict_list, logging_df
 
-def process_biomarker_detail(biomarker_detail):
+def process_biomarker_detail(args):
+    biomarker_detail, df_list, logging_df = args
     attributes = biomarker_detail['attribute']
     for attribute in attributes:
         attribute_details = attribute['attribute_details']
@@ -81,6 +82,7 @@ def process_biomarker_detail(biomarker_detail):
 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_details)
+        updated_biomarker_details = pool.map(process_biomarker_detail, [(biomarker_detail, df_list, logging_df) for biomarker_detail in biomarker_details])
     json_data['patient_level']['biomarkers']['details'] = updated_biomarker_details
     return json_data, logging_df
+