From fc601cbf3ca471e8d57359487700da6e46a6ce45 Mon Sep 17 00:00:00 2001 From: Roman Date: Mon, 21 Oct 2024 14:24:45 +0200 Subject: [PATCH] add .parquet for the notices file stored in hdfs --- fink_mm/gcn_stream/gcn_stream.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fink_mm/gcn_stream/gcn_stream.py b/fink_mm/gcn_stream/gcn_stream.py index 16e72636..c4a004a4 100644 --- a/fink_mm/gcn_stream/gcn_stream.py +++ b/fink_mm/gcn_stream/gcn_stream.py @@ -185,7 +185,7 @@ def load_and_parse_gcn( table, root_path=gcn_rawdatapath, partition_cols=["year", "month", "day"], - basename_template="{}_{}_{}".format( + basename_template="{}_{}_{}.parquet".format( str(df["triggerId"].values[0]), time.time(), "{i}" ), existing_data_behavior="overwrite_or_ignore",