re-blacken

dias/__init__.py

@@ -1,4 +1,5 @@
 """dias, a data integrity analysis system."""
+
 from .exception import DiasException, DiasUsageError, DiasConfigError
 from .exception import DiasConcurrencyError
 from .analyzer import Analyzer

dias/analyzer.py

@@ -1,4 +1,5 @@
 """Analyzer Base Class."""
+
 import logging
 import os
 import re

dias/analyzers/__init__.py

@@ -1,4 +1,5 @@
 """Analyzers for dias."""
+
 from .feedpositions_analyzer import FeedpositionsAnalyzer
 from .sample_analyzer import SampleAnalyzer
 from .test_analyzer import TestAnalyzer

dias/analyzers/daily_ringmaps.py

@@ -1,4 +1,5 @@
 """Analyzer to retrieve and store daily ringmaps."""
+
 import numpy as np
 import requests
 import msgpack

dias/analyzers/feedpositions_analyzer.py

@@ -3,6 +3,7 @@
 
 Note: This analyzer has been turned off since 2021-01-21.
 """
+
 from dias import CHIMEAnalyzer, DiasConfigError
 from datetime import datetime, timedelta
 from caput import config, time

dias/analyzers/find_jump_analyzer.py

@@ -21,6 +21,7 @@
     finger_finder
 
 """
+
 import os
 import time
 import datetime

dias/analyzers/flag_rfi_analyzer.py

@@ -18,6 +18,7 @@
     :toctree: generated/
 
 """
+
 import os
 import time
 import datetime

dias/analyzers/sample_analyzer.py

@@ -3,7 +3,6 @@
 This is a basic example for how to write an analyzer for dias.
 """
 
-
 from dias import CHIMEAnalyzer
 from datetime import datetime
 from caput import config

dias/analyzers/sensitivity_analyzer.py

@@ -243,9 +243,7 @@ def run(self):
                 ):
                     cnt[ss, :] += flag_ind[pp[0], :] * flag_ind[pp[1], :]
             else:
-                for ss, val in Counter(
-                    data.reverse_map["stack"]["stack"][:]
-                ).items():
+                for ss, val in Counter(data.reverse_map["stack"]["stack"][:]).items():
                     cnt[ss, :] = val
 
             # Initialize arrays

dias/analyzers/test_analyzer.py

@@ -1,4 +1,5 @@
 """Analyzer to test the dias scheduler."""
+
 from dias import Analyzer
 from dias.utils import str2timedelta
 from time import sleep

dias/config_loader.py

@@ -1,4 +1,5 @@
 """dias config loader."""
+
 import importlib
 import logging
 import yaml

dias/job.py

@@ -1,4 +1,5 @@
 """dias Job."""
+
 from dias import DiasConcurrencyError
 
 

dias/scheduler.py

@@ -1,4 +1,5 @@
 """dias Scheduler."""
+
 import concurrent.futures
 import logging
 import threading

dias/task.py

@@ -1,4 +1,5 @@
 """dias Task."""
+
 import os
 import random
 import traceback

dias/task_queue.py

@@ -1,4 +1,5 @@
 """dias task queue."""
+
 import threading
 
 

dias/utils/__init__.py

@@ -1,4 +1,5 @@
 """Utilities for dias."""
+
 from .string_converter import *
 from .helpers import *
 from .tracker import *

dias/utils/string_converter.py

@@ -1,4 +1,5 @@
 """Helper functions to convert to and from strings."""
+
 from dias.exception import DiasException
 
 import os
@@ -42,7 +43,7 @@ def str2timedelta(time_str):
         return
     parts = parts.groupdict()
     time_params = {}
-    for (name, param) in parts.items():
+    for name, param in parts.items():
         if param:
             time_params[name] = int(param)
     if not time_params: