diff --git a/python/common/recluster.py b/python/common/recluster.py index 1bfd486..8a17e68 100644 --- a/python/common/recluster.py +++ b/python/common/recluster.py @@ -119,10 +119,7 @@ async def load_preprocess_files( df["tst_median"], format="ISO8601" ).dt.tz_convert("UTC") dfs.append(df) - if "tst_median" in df.columns: - df["tst_median"] = pd.to_datetime(df["tst_median"], format="ISO8601", utc=True).dt.tz_convert( - "UTC" - ) + if not dfs: return None