Forgot these

datastore/data-loader/client_fmi_station.py

@@ -7,7 +7,8 @@
 from multiprocessing import cpu_count
 from pathlib import Path
 from time import perf_counter
-from typing import List, Tuple
+from typing import List
+from typing import Tuple
 
 import datastore_pb2 as dstore
 import datastore_pb2_grpc as dstore_grpc

datastore/data-loader/client_knmi_station.py

@@ -7,7 +7,8 @@
 from multiprocessing import cpu_count
 from pathlib import Path
 from time import perf_counter
-from typing import List, Tuple
+from typing import List
+from typing import Tuple
 
 import datastore_pb2 as dstore
 import datastore_pb2_grpc as dstore_grpc

datastore/examples/big_input_workaround/client.py

@@ -17,7 +17,8 @@
 import os
 import sys
 from collections import deque
-from datetime import datetime, timezone
+from datetime import datetime
+from datetime import timezone
 
 import datastore_pb2 as dstore
 import datastore_pb2_grpc as dstore_grpc

datastore/examples/clients/python/client.py

@@ -3,7 +3,8 @@
 # Generate protobuf code with following command from top level directory:
 # python -m grpc_tools.protoc --proto_path=datastore/protobuf datastore.proto --python_out=examples/clients/python --grpc_python_out=examples/clients/python  # noqa: E501
 import os
-from datetime import datetime, timezone
+from datetime import datetime
+from datetime import timezone
 
 import datastore_pb2 as dstore
 import datastore_pb2_grpc as dstore_grpc

datastore/load-test/grpc_user.py

@@ -1,5 +1,6 @@
 import time
-from typing import Any, Callable
+from typing import Any
+from typing import Callable
 
 import grpc
 import grpc.experimental.gevent as grpc_gevent

datastore/load-test/locustfile.py

@@ -9,7 +9,8 @@
 import grpc_user
 from google.protobuf.timestamp_pb2 import Timestamp
 from locust import task
-from shapely import buffer, wkt
+from shapely import buffer
+from shapely import wkt
 
 parameters = ["ff", "dd", "rh", "pp", "tn"]
 # fmt: off

datastore/tstester/pgopbackend.py

@@ -1,5 +1,6 @@
 import sys
-from abc import ABC, abstractmethod
+from abc import ABC
+from abc import abstractmethod
 
 import common
 import psycopg2

datastore/tstester/postgissbe.py

@@ -2,7 +2,8 @@
 import sys
 
 import common
-from pgopbackend import PsqlBE, Psycopg2BE
+from pgopbackend import PsqlBE
+from pgopbackend import Psycopg2BE
 from storagebackend import StorageBackend
 
 # NOTE: we assume that the risk of SQL injection is zero in this context

datastore/tstester/storagebackend.py

@@ -1,4 +1,5 @@
-from abc import ABC, abstractmethod
+from abc import ABC
+from abc import abstractmethod
 
 
 class StorageBackend(ABC):

datastore/tstester/timescaledbsbe.py

@@ -2,7 +2,8 @@
 import sys
 
 import common
-from pgopbackend import PsqlBE, Psycopg2BE
+from pgopbackend import PsqlBE
+from pgopbackend import Psycopg2BE
 from storagebackend import StorageBackend
 
 # NOTE: we assume that the risk of SQL injection is zero in this context

datastore/tstester/tstester.py

@@ -3,7 +3,8 @@
 import json
 import random
 import sys
-from abc import ABC, abstractmethod
+from abc import ABC
+from abc import abstractmethod
 
 import common
 from netcdfsbe_tsmdatainpostgis import NetCDFSBE_TSMDataInPostGIS

ingest/src/esoh/ingest/messages.py

@@ -1,6 +1,7 @@
 import logging
 import uuid
-from datetime import datetime, timezone
+from datetime import datetime
+from datetime import timezone
 
 import xarray as xr
 from esoh.ingest.bufr.create_mqtt_message_from_bufr import (

ingest/test/test_verify_json_payloads.py

@@ -3,13 +3,12 @@
 
 import pytest
 import xarray as xr
-from esoh.ingest.bufr.bufresohmsg_py import (
-    init_bufr_schema_py,
-    init_bufrtables_py,
-    init_oscar_py,
-)
+from esoh.ingest.bufr.bufresohmsg_py import init_bufr_schema_py
+from esoh.ingest.bufr.bufresohmsg_py import init_bufrtables_py
+from esoh.ingest.bufr.bufresohmsg_py import init_oscar_py
 from esoh.ingest.main import IngestToPipeline
-from jsonschema import Draft202012Validator, ValidationError
+from jsonschema import Draft202012Validator
+from jsonschema import ValidationError
 
 
 @pytest.mark.timeout(1000)