Cast numpy array into list for Spark operation

astrolabsoftware · Jan 18, 2024 · e560744 · e560744
1 parent 980f74b
commit e560744
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bin/daily_stats.py b/bin/daily_stats.py
@@ -108,7 +108,7 @@ def main():
     out_dic['simbad_tot'] = n_simbad
 
     n_simbad_gal = df_sci.select('cdsxmatch')\
-        .filter(df_sci['cdsxmatch'].isin(return_list_of_eg_host()))\
+        .filter(df_sci['cdsxmatch'].isin(list(return_list_of_eg_host())))\
         .count()
 
     out_dic['simbad_gal'] = n_simbad_gal