flake8

python/lsst/consdb/client.py

@@ -16,7 +16,7 @@ def insert(table: str, values: dict[str, Any], **kwargs):
     url = urljoin(base_url, "insert")
     try:
         response = requests.post(url, json=data)
-    except (RequestException) as e:
+    except RequestException as e:
         raise e
     response.raise_for_status()
 
@@ -36,8 +36,8 @@ def query(
     data = {"tables": tables, "columns": columns, "where": where, "join": join}
     try:
         response = requests.post(url, json=data)
-    except (RequestException) as e:
-       raise e
+    except RequestException as e:
+        raise e
     try:
         response.raise_for_status()
     except:
@@ -52,7 +52,7 @@ def schema(table: str):
     url = urljoin(url, table)
     try:
         response = requests.get(url)
-    except (RequestException) as e:
+    except RequestException as e:
         raise e
     response.raise_for_status()
     return response.json()

python/lsst/consdb/hinfo-latiss.py

@@ -15,21 +15,24 @@
 # import Kafka interface
 
 
-
 def ninety_minus(angle: float) -> float:
     return 90.0 - angle
 
+
 def tai_convert(t: str) -> datetime:
     return Time(t, format="isot", scale="tai").datetime
 
+
 def tai_mean(start: str, end: str) -> datetime:
     s = Time(start, format="isot", scale="tai")
     e = Time(end, format="isot", scale="tai")
     return (s + (e - s) / 2).datetime
 
+
 def mean(*iterable: Iterable[Any]) -> Any:
     return sum(iterable) / len(iterable)
 
+
 def logical_or(*bools: Iterable[int | str | None]) -> bool:
     return any([b == 1 or b == "1" for b in bools])
 
@@ -77,8 +80,9 @@ def logical_or(*bools: Iterable[int | str | None]) -> bool:
     "dome_azimuth": "DOMEAZ",
     "shut_lower": "SHUTLOWR",
     "shut_upper": "SHUTUPPR",
-#     "temp_set": "TEMP_SET",
-    "simulated": (logical_or, "SIMULATE ATMCS", "SIMULATE ATHEXAPOD", "SIMULAT ATPNEUMATICS", "SIMULATE ATDOME", "SIMULATE ATSPECTROGRAPH"),
+    #     "temp_set": "TEMP_SET",
+    "simulated": (logical_or, "SIMULATE ATMCS", "SIMULATE ATHEXAPOD", "SIMULAT ATPNEUMATICS",
+                  "SIMULATE ATDOME", "SIMULATE ATSPECTROGRAPH"),
 }
 
 # LATISS_DETECTOR_MAPPING = {
@@ -116,6 +120,7 @@ def process_keyword(keyword: str | tuple, info: dict) -> Any:
         if all([a in info for a in args]):
             return fn(*[info[a] for a in args])
 
+
 def process_resource(resource: ResourcePath) -> None:
     global engine, exposure_table
 
@@ -145,7 +150,8 @@ def process_resource(resource: ResourcePath) -> None:
 
     stmt = insert(exposure_table).values(exposure_rec).on_conflict_do_nothing()
     with engine.begin() as conn:
-        result = conn.execute(stmt)
+        conn.execute(stmt)
+        # result = conn.execute(stmt)
 
     # print(exposure_rec)