Weather-mv version bumping to 0.2.16.

dabhicusp · Jul 11, 2023 · dae9d07 · dae9d07
1 parent dc419ae
commit dae9d07
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 7 deletions.
diff --git a/weather_mv/loader_pipeline/bq.py b/weather_mv/loader_pipeline/bq.py
@@ -264,12 +264,11 @@ def extract_rows(self, uri: str, coordinates: t.List[t.Dict]) -> t.Iterator[t.Di
 
                 longitude = ((row['longitude'] + 180) % 360) - 180
                 row[GEO_POINT_COLUMN] = fetch_geo_point(row['latitude'], longitude)
-
-                if not self.skip_creating_polygon:
-                    row[GEO_POLYGON_COLUMN] = fetch_geo_polygon(row['latitude'], longitude,
-                                                                self.lat_grid_resolution, self.lon_grid_resolution)
-                else:
-                    row[GEO_POLYGON_COLUMN] = None
+                row[GEO_POLYGON_COLUMN] = (
+                    fetch_geo_polygon(row["latitude"], longitude, self.lat_grid_resolution, self.lon_grid_resolution)
+                    if not self.skip_creating_polygon
+                    else None
+                )
                 # 'row' ends up looking like:
                 # {'latitude': 88.0, 'longitude': 2.0, 'time': '2015-01-01 06:00:00', 'd': -2.0187, 'cc': 0.007812,
                 #  'z': 50049.8, 'data_import_time': '2020-12-05 00:12:02.424573 UTC', ...}

diff --git a/weather_mv/setup.py b/weather_mv/setup.py
@@ -62,7 +62,7 @@
     packages=find_packages(),
     author='Anthromets',
     author_email='anthromets-ecmwf@google.com',
-    version='0.2.15',
+    version='0.2.16',
     url='https://weather-tools.readthedocs.io/en/latest/weather_mv/',
     description='A tool to load weather data into BigQuery.',
     install_requires=beam_gcp_requirements + base_requirements,