diff --git a/python/common/recluster.py b/python/common/recluster.py
index 5533d8d..90416f6 100644
--- a/python/common/recluster.py
+++ b/python/common/recluster.py
@@ -114,6 +114,10 @@ async def load_preprocess_files(
         decompressed_csv = decompressor.decompress(compressed_data)
         df = pd.read_csv(io.BytesIO(decompressed_csv), sep=";")
         dfs.append(df)
+        if "tst_median" in df.columns:
+            df["tst_median"] = pd.to_datetime(df["tst_median"], format="ISO8601").dt.tz_convert(
+                "UTC"
+            )
 
     if not dfs:
         return None