linting

src/pyaro_readers/actrisebas/ActrisEbasReader.py

@@ -64,11 +64,11 @@ class ActrisEbasTestDataNotFoundException(Exception):
 
 class ActrisEbasTimeSeriesReader(AutoFilterReaderEngine.AutoFilterReader):
     def __init__(
-            self,
-            filters=[],
-            tqdm_desc: str | None = None,
-            ts_type: str = "daily",
-            test_flag: bool = True,
+        self,
+        filters=[],
+        tqdm_desc: str | None = None,
+        ts_type: str = "daily",
+        test_flag: bool = True,
     ):
         """ """
         self._filename = None
@@ -134,9 +134,9 @@ def metadata(self):
         return self._metadata
 
     def read_data(
-            self,
-            urls_to_dl: dict,
-            tqdm_desc="reading stations",
+        self,
+        urls_to_dl: dict,
+        tqdm_desc="reading stations",
     ):
         """
         read the data from EBAS thredds server
@@ -158,9 +158,9 @@ def read_data(
 
                 # put all data variables in the data struct for the moment
                 for d_idx, _data_var in enumerate(
-                        self._get_ebas_data_vars(
-                            tmp_data,
-                        )
+                    self._get_ebas_data_vars(
+                        tmp_data,
+                    )
                 ):
                     # the naming of the variable in the file does not reflect the vocabulary naming ot pyaerocom's
                     # naming
@@ -234,8 +234,8 @@ def _get_ebas_data_vars(self, tmp_data, actris_var: str = None, units: str = Non
                 try:
                     # if defined, return only names that match
                     if (
-                            tmp_data[data_var].attrs["units"]
-                            == self._def_data["actris_std_units"][data_var]
+                        tmp_data[data_var].attrs["units"]
+                        == self._def_data["actris_std_units"][data_var]
                     ):
                         data_vars.append(data_var)
                 except KeyError:
@@ -244,10 +244,10 @@ def _get_ebas_data_vars(self, tmp_data, actris_var: str = None, units: str = Non
         return data_vars
 
     def extract_urls(
-            self,
-            json_resp: dict,
-            sites_to_read: list[str] = [],
-            sites_to_exclude: list[str] = [],
+        self,
+        json_resp: dict,
+        sites_to_read: list[str] = [],
+        sites_to_exclude: list[str] = [],
     ) -> dict:
         """
         small helper method to extract URLs to download from json reponse from the EBAS API
@@ -267,11 +267,11 @@ def extract_urls(
                 # site_data[DISTRIBUTION_ROOT_KEY] is also a list
                 # search for protocol DISTRIBUTION_PROTOCOL_NAME
                 for url_idx, distribution_data in enumerate(
-                        site_data[DISTRIBUTION_ROOT_KEY]
+                    site_data[DISTRIBUTION_ROOT_KEY]
                 ):
                     if (
-                            distribution_data[DISTRIBUTION_PROTOCOL_KEY]
-                            != DISTRIBUTION_PROTOCOL_NAME
+                        distribution_data[DISTRIBUTION_PROTOCOL_KEY]
+                        != DISTRIBUTION_PROTOCOL_NAME
                     ):
                         continue
                     else:

tests/test_ActrisEbasReader.py

@@ -58,7 +58,7 @@ def test_api_reading_small_data_set(self):
         engine = pyaro.list_timeseries_engines()[self.engine]
         #
         with engine.open(
-                filters=filters,
+            filters=filters,
         ) as ts:
             self.assertGreaterEqual(len(ts.variables()), 1)
 
@@ -75,7 +75,7 @@ def test_api_reading_pyaerocom_naming(self):
         engine = pyaro.list_timeseries_engines()[self.engine]
         #
         with engine.open(
-                filters=filters,
+            filters=filters,
         ) as ts:
             self.assertGreaterEqual(len(ts.variables()), 1)