diff --git a/modules/cold-extraction/ColdDataRetriever.py b/modules/cold-extraction/ColdDataRetriever.py
index 10a122f..24c863c 100644
--- a/modules/cold-extraction/ColdDataRetriever.py
+++ b/modules/cold-extraction/ColdDataRetriever.py
@@ -138,6 +138,9 @@ def initialize():
             date_str = dt_stamp.strftime('%Y%m%d')
             dates.append(date_str)
             length = len(patients)
+        elif (extraction_type == 'empi'):
+            patients.append(row[patient_index])
+            length = len(patients)
         elif (extraction_type == 'accession'):
             accessions.append(row[accession_index])
             length = len(accessions)