From e560744b16aa46989bcb6cf7ebcd9646efd5f8f8 Mon Sep 17 00:00:00 2001 From: JulienPeloton Date: Thu, 18 Jan 2024 14:54:27 +0100 Subject: [PATCH] Cast numpy array into list for Spark operation --- bin/daily_stats.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/bin/daily_stats.py b/bin/daily_stats.py index 7ab9a996..fe448fa0 100644 --- 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