fixes flake8

Signed-off-by: nagesh bansal <nageshbansal59@gmail.com>
weecology · Sep 18, 2023 · 08d1f34 · 08d1f34
1 parent ca041d8
commit 08d1f34
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 8 deletions.
diff --git a/neonwranglerpy/fetcher/fetcher.py b/neonwranglerpy/fetcher/fetcher.py
@@ -67,7 +67,11 @@ async def _download(session, url, filename, sem, size=None):
                         # update_progressbar(progress, size)
 
 
-async def _fetcher(data, rate_limit, headers, files_to_stack_path="filesToStack", data_type="vst"):
+async def _fetcher(data,
+                   rate_limit,
+                   headers,
+                   files_to_stack_path="filesToStack",
+                   data_type="vst"):
     """Fetcher for downloading files."""
     sem = asyncio.Semaphore(rate_limit)
     data = data['data']
@@ -76,8 +80,9 @@ async def _fetcher(data, rate_limit, headers, files_to_stack_path="filesToStack"
     sizes = [f['size'] for f in data["files"]]
     f_names = [f['name'] for f in data["files"]]
     if data_type == "vst":
-        dir_name = '.'.join(
-            ['NEON', data['productCode'], data['siteCode'], data['month'], data['release']])
+        dir_name = '.'.join([
+            'NEON', data['productCode'], data['siteCode'], data['month'], data['release']
+        ])
         zip_dir_path = os.path.join(files_to_stack_path, f'{dir_name}')
         if not os.path.isdir(zip_dir_path):
             os.mkdir(zip_dir_path)
@@ -117,7 +122,8 @@ def fetcher(batch, data_type, rate_limit, headers, files_to_stack_path):
         if data_type == 'vst':
             asyncio.run(vst_fetcher(batch, rate_limit, headers, files_to_stack_path))
         elif data_type == 'aop':
-            asyncio.run(_fetcher(batch, rate_limit, headers, files_to_stack_path, data_type))
+            asyncio.run(
+                _fetcher(batch, rate_limit, headers, files_to_stack_path, data_type))
 
     except Exception as e:
         print(f"Error processing URLs: {e}")

diff --git a/neonwranglerpy/lib/retrieve_aop_data.py b/neonwranglerpy/lib/retrieve_aop_data.py
@@ -23,10 +23,10 @@ def retrieve_aop_data(data, year=2019, dpID=['DP3.30006.001'], savepath=""):
     """
     coords_for_tiles = data[['plotID', 'siteID', 'utmZone', 'easting', 'northing']]
     # get tiles dimensions
-    coords_for_tiles['easting'] = (coords_for_tiles[['easting']] /
-                                   1000).astype(int, errors='ignore') * 1000
-    coords_for_tiles['northing'] = (coords_for_tiles[['northing']] /
-                                    1000).astype(int, errors='ignore') * 1000
+    coords_for_tiles['easting'] = (coords_for_tiles[['easting']] / 1000).astype(
+        int, errors='ignore') * 1000
+    coords_for_tiles['northing'] = (coords_for_tiles[['northing']] / 1000).astype(
+        int, errors='ignore') * 1000
     # if there are more than 1 row, drop duplicates
     if coords_for_tiles.easting.shape[0] > 1:
         # drop duplicates values