Fix processing of numerical data to save to the database.

1 files changed, 10 insertions, 6 deletions

diff --git a/scripts/load_phenotypes_to_db.py b/scripts/load_phenotypes_to_db.py
index 0797db5..0e7c5b6 100644
--- a/scripts/load_phenotypes_to_db.py
+++ b/scripts/load_phenotypes_to_db.py
@@ -115,13 +115,13 @@ def save_pheno_data(
     return save_phenotypes_data(
         conn,
         "PublishData",
-        (item for item in
         (item for items in
          (__row_to_dataitems__(dict(zip(_headers, line)), samples)
           for filecontent
           in (rqtl2.read_csv_file(path) for path in phenofiles)
          for idx, line in enumerate(filecontent)
-         if idx != 0)))
+         if idx != 0)
+         for item in items))
 
 
 def save_phenotype_se(
@@ -154,13 +154,13 @@ def save_phenotype_se(
     return save_phenotypes_data(
         conn,
         "PublishSE",
-        (item for item in
         (item for items in
          (__row_to_dataitems__(dict(zip(_headers, line)), samples)
           for filecontent
           in (rqtl2.read_csv_file(path) for path in sefiles)
          for idx, line in enumerate(filecontent)
-         if idx != 0)))
+         if idx != 0)
+         for item in items))
 
 
 def save_phenotype_n(
@@ -193,9 +193,13 @@ def save_phenotype_n(
     return save_phenotypes_data(
         conn,
         "NStrain",
-        (item for item in
+        (item for items in
+         (__row_to_dataitems__(dict(zip(_headers, line)), samples)
+          for filecontent
+          in (rqtl2.read_csv_file(path) for path in nfiles)
          for idx, line in enumerate(filecontent)
-         if idx != 0)))
+         if idx != 0)
+         for item in items))
 
 
 def cross_reference_phenotypes_publications_and_data(