From 12bf5fcf94201ab2fcfdf9aeada05b8cca85fe8c Mon Sep 17 00:00:00 2001 From: FusRoman <46221629+FusRoman@users.noreply.github.com> Date: Mon, 21 Oct 2024 15:34:52 +0200 Subject: [PATCH] add .parquet for the notices file stored in hdfs (#122) * add .parquet for the notices file stored in hdfs * bump to 0.21.1 --- fink_mm/__init__.py | 2 +- fink_mm/gcn_stream/gcn_stream.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/fink_mm/__init__.py b/fink_mm/__init__.py index c9599501..c8e3d570 100644 --- a/fink_mm/__init__.py +++ b/fink_mm/__init__.py @@ -12,6 +12,6 @@ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. -__version__ = "0.21.0" +__version__ = "0.21.1" __distribution_schema_version__ = "1.3" __observatory_schema_version__ = "1.1" 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",