diff --git a/bin/daily_stats.py b/bin/daily_stats.py
index 697757a1..7ab9a996 100644
--- a/bin/daily_stats.py
+++ b/bin/daily_stats.py
@@ -20,6 +20,8 @@
 import numpy as np
 import pandas as pd
 
+import pyspark.sql.functions as F
+
 from fink_broker.sparkUtils import init_sparksession
 from fink_broker.hbaseUtils import push_to_hbase
 from fink_broker.parser import getargs