pep8

astrolabsoftware · Feb 29, 2024 · 197350f · 197350f
1 parent 0f1a21a
commit 197350f
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/fink_broker/mm2distribute.py b/fink_broker/mm2distribute.py
@@ -39,11 +39,11 @@ def mm2distribute(spark, config, args):
             time.sleep(wait)
             wait *= 1.2 if wait < 60 else 1
             continue
-    
+
     df_grb_stream = df_grb_stream\
-    .drop("brokerEndProcessTimestamp")\
-    .drop("brokerStartProcessTimestamp")\
-    .drop("brokerIngestTimestamp")
+        .drop("brokerEndProcessTimestamp")\
+        .drop("brokerStartProcessTimestamp")\
+        .drop("brokerIngestTimestamp")
 
     stream_distribute_list = grb_distribution_stream(
         df_grb_stream,