From 79063798be4c136d263544cee153b0bec5c718a5 Mon Sep 17 00:00:00 2001 From: FusRoman Date: Thu, 1 Sep 2022 07:48:22 +0000 Subject: [PATCH] pep8 requirements --- fink_grb/online/gcn_stream.py | 12 +++++++----- fink_grb/online/ztf_join_gcn.py | 4 +--- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/fink_grb/online/gcn_stream.py b/fink_grb/online/gcn_stream.py index b2f9cf534..e490ffe6b 100644 --- a/fink_grb/online/gcn_stream.py +++ b/fink_grb/online/gcn_stream.py @@ -45,7 +45,7 @@ def load_and_parse_gcn(gcn, gcn_rawdatapath, logger, logs=False): logger : logger object logger object for logs. - Returns + Returns ------- None @@ -135,7 +135,6 @@ def start_gcn_stream(arguments, logs=False): logger.error("Config entry not found \n\t {}".format(e)) exit(1) - # Subscribe to topics and receive alerts consumer.subscribe(INSTR_SUBSCRIBES) @@ -149,15 +148,18 @@ def start_gcn_stream(arguments, logs=False): exit(1) if not os.path.exists(gcn_rawdatapath): - logger.error("Path of the gcn stream output not found : {}\nRun fink_grb init before".format(gcn_rawdatapath)) - + logger.error( + "Path of the gcn stream output not found : {}\nRun fink_grb init before".format( + gcn_rawdatapath + ) + ) while True: message = consumer.consume(timeout=2) if len(message) != 0: for gcn in message: - + if logs: logger.info("A new voevent is coming") value = gcn.value() diff --git a/fink_grb/online/ztf_join_gcn.py b/fink_grb/online/ztf_join_gcn.py index 227226cd5..c9364c031 100644 --- a/fink_grb/online/ztf_join_gcn.py +++ b/fink_grb/online/ztf_join_gcn.py @@ -1,7 +1,4 @@ import warnings - -warnings.filterwarnings("ignore") - import pandas as pd import numpy as np import time @@ -23,6 +20,7 @@ from fink_grb.init import get_config, init_logging from fink_broker.science import ang2pix +warnings.filterwarnings("ignore") def compute_healpix_column(spark_df, ra, dec, nside): """