pep8 requirements

.flake8

@@ -8,4 +8,6 @@ exclude =
     docs/source/conf.py,
     old,
     build,
-    dist
+    dist
+per-file-ignores =
+    ../Fink_GRB/fink_grb/online/ztf_join_gcn.py:W503

fink_grb/init.py

@@ -3,6 +3,8 @@
 from importlib.resources import files
 import logging
 
+from fink_grb import __name__
+
 
 def init_fink_grb(arguments):
     """

fink_grb/online/gcn_stream.py

@@ -11,8 +11,6 @@
 import fink_grb.online.gcn_reader as gr
 from fink_grb.init import get_config, init_logging
 
-from fink_grb import __name__
-
 
 def signal_handler(signal, frame):
     """

fink_grb/online/ztf_join_gcn.py

@@ -7,7 +7,7 @@
 from astropy.time import Time
 
 from pyspark.sql import functions as F
-from pyspark.sql.functions import pandas_udf, current_timestamp, expr, col
+from pyspark.sql.functions import pandas_udf
 from pyspark.sql.types import DoubleType
 
 from fink_broker.sparkUtils import init_sparksession, connect_to_raw_database
@@ -90,17 +90,17 @@ def ztf_join_gcn_stream(arguments):
 
     config = get_config(arguments)
     logger = init_logging()
-    spark = init_sparksession("fink_grb")
+    _ = init_sparksession("fink_grb")
 
     NSIDE = 4
 
     night = arguments["--night"]
     exit_after = arguments["--exit_after"]
 
     ztf_datapath_prefix = config["PATH"]["online_ztf_data_prefix"]
-    ztf_rawdatapath = ztf_datapath_prefix + '/raw'
-    scitmpdatapath = ztf_datapath_prefix + '/science'
-    checkpointpath_sci_tmp = ztf_datapath_prefix + '/science_checkpoint'
+    ztf_rawdatapath = ztf_datapath_prefix + "/raw"
+    scitmpdatapath = ztf_datapath_prefix + "/science"
+    checkpointpath_sci_tmp = ztf_datapath_prefix + "/science_checkpoint"
 
     df_ztf_stream = connect_to_raw_database(
         ztf_rawdatapath