Small tweaks to docstrings, remove use of default mutable argument, fix minor security problem, attach whl to GitHub releases.

.github/workflows/github-release.yml

@@ -24,11 +24,14 @@ jobs:
           version=$(python -c "from eedl import __version__; print(__version__)")
           echo "VERSION=$version" >> $GITHUB_ENV
 
+      - name: Build WHL file
+        run: |
+          pip install setuptools wheel
+          python setup.py bdist_wheel
 
-      - name: Create a Release
-        uses: elgohr/Github-Release-Action@v5
+      - name: Create and attach whl to Release
         env:
           GH_TOKEN: ${{ github.token }}
 
-        with:
-          title: ${{ env.VERSION }}
+        run: |
+          gh release create ${{env.VERSION}} ./dist/*.whl --generate-notes

eedl/__init__.py

@@ -1 +1 @@
-__version__ = "0.2023.10.18"
+__version__ = "0.2023.11.13"

eedl/core.py

@@ -26,10 +26,10 @@ def _get_fiona_args(polygon_path: Union[str, Path]) -> Dict[str, Union[str, Path
 
 def safe_fiona_open(features_path: Union[str, Path], **extra_kwargs) -> fiona.Collection:
 	"""
-		Handles opening things in fiona in a way that is safe, even for geodatabases where we need
-		to open the geodatabase itself and specify a layer. The caller is responsible for
-		ensuring the features are closed (e.g. a try/finally block with a call to features.close()
-		in the finally block should immediately follow calling this function.
+	Handles opening things in fiona in a way that is safe, even for geodatabases where we need
+	to open the geodatabase itself and specify a layer. The caller is responsible for
+	ensuring the features are closed (e.g. a try/finally block with a call to features.close())
+	in the finally block should immediately follow calling this function.
 	:param features_path: A Path object or string path to open with fiona
 	:param extra_kwargs: Keyword arguments to directly pass through to fiona. Helpful when trying to filter features, etc
 	:return:

eedl/helpers.py

@@ -56,11 +56,20 @@ def __init__(self, **kwargs):
 
 	def _single_item_extract(self, image, task_registry, zonal_features, aoi_attr, ee_geom, image_date, aoi_download_folder):
 		"""
-			This looks a bit silly here, but we need to construct this here so that we have access
-			to this method's variables since we can't pass them in and it can't be a class function.
-			:param image:
-			:param state:
-			:return:
+		This looks a bit silly here, but we need to construct this here so that we have access
+		to this method's variables since we can't pass them in and it can't be a class function.
+
+		Args:
+			image:
+			task_registry:
+			zonal_features:
+			aoi_attr:
+			ee_geom:
+			image_date:
+			aoi_download_folder:
+
+		Returns:
+			None
 		"""
 
 		export_image = EEDLImage(
@@ -147,8 +156,8 @@ def extract(self):
 							zonal_features = zonal_features_filtered
 
 						image = aoi_collection.filter(ee.Filter.eq("system:time_start", image_info[1])).first()  # Get the image from the collection again based on ID.
-						timsetamp_in_seconds = int(str(image_info[1])[:-3])  # We could divide by 1000, but then we'd coerce back from a float. This is precise.
-						date_string = datetime.datetime.fromtimestamp(timsetamp_in_seconds, tz=datetime.timezone.utc).strftime("%Y-%m-%d")
+						timestamp_in_seconds = int(str(image_info[1])[:-3])  # We could divide by 1000, but then we'd coerce back from a float. This is precise.
+						date_string = datetime.datetime.fromtimestamp(timestamp_in_seconds, tz=datetime.timezone.utc).strftime("%Y-%m-%d")
 
 						self._single_item_extract(image, task_registry, zonal_features, aoi_attr, ee_geom, date_string, aoi_download_folder)
 
@@ -188,9 +197,9 @@ def _get_and_filter_collection(self):
 
 def mosaic_by_date(image_collection):
 	"""
-		Adapted to Python from code found via https://gis.stackexchange.com/a/343453/1955
-		:param image_collection: An image collection
-		:return: ee.ImageCollection
+	Adapted to Python from code found via https://gis.stackexchange.com/a/343453/1955
+	:param image_collection: An image collection
+	:return: ee.ImageCollection
 	"""
 	image_list = image_collection.toList(image_collection.size())
 

eedl/image.py

@@ -81,7 +81,7 @@ def __init__(self) -> None:
 		self.log_file: Optional[io.TextIOWrapper] = None  # the open log file handle
 		self.raise_errors: bool = True
 
-	def add(self, image: ee.image.Image) -> None:
+	def add(self, image: "EEDLImage") -> None:
 		"""
 		Adds an Earth Engine image to the list of Earth Engine images.
 
@@ -94,7 +94,7 @@ def add(self, image: ee.image.Image) -> None:
 		self.images.append(image)
 
 	@property
-	def incomplete_tasks(self) -> List[ee.image.Image]:
+	def incomplete_tasks(self) -> List["EEDLImage"]:
 		"""
 		List of Earth Engine images that have not been completed yet.
 
@@ -108,7 +108,7 @@ def incomplete_tasks(self) -> List[ee.image.Image]:
 		return [image for image in self.images if image.last_task_status['state'] in self.INCOMPLETE_STATUSES]
 
 	@property
-	def complete_tasks(self) -> List[ee.image.Image]:
+	def complete_tasks(self) -> List["EEDLImage"]:
 		"""
 		List of Earth Engine images.
 
@@ -118,7 +118,7 @@ def complete_tasks(self) -> List[ee.image.Image]:
 		return [image for image in self.images if image.last_task_status['state'] in self.COMPLETE_STATUSES + self.FAILED_STATUSES]
 
 	@property
-	def failed_tasks(self) -> List[ee.image.Image]:
+	def failed_tasks(self) -> List["EEDLImage"]:
 		"""
 		List of Earth Engine images that have either been cancelled or that have failed
 
@@ -128,7 +128,7 @@ def failed_tasks(self) -> List[ee.image.Image]:
 		return [image for image in self.images if image.last_task_status['state'] in self.FAILED_STATUSES]
 
 	@property
-	def downloadable_tasks(self) -> List[ee.image.Image]:
+	def downloadable_tasks(self) -> List["EEDLImage"]:
 		"""
 		List of Earth Engine images that have not been cancelled or have failed.
 
@@ -165,9 +165,12 @@ def setup_log(self, log_file_path: Union[str, Path], mode='a'):
 
 	def log_error(self, error_type: str, error_message: str):
 		"""
-			:param error_type: Options "ee", "local" to indicate whether it was an error on Earth Engine's side or on
-				the local processing side
-			:param error_message: The error message to print to the log file
+		Args:
+			error_type (str): Options "ee", "local" to indicate whether it was an error on Earth Engine's side or on the local processing side
+			error_message (str): The error message to print to the log file
+
+		Returns:
+			None
 		"""
 		message = f"{error_type} Error: {error_message}"
 		date_string = datetime.datetime.now().strftime("%Y-%m-%d %H:%M")
@@ -215,15 +218,15 @@ def wait_for_images(self,
 				self.download_ready_images(download_location)
 			except OSError:
 				if try_again_disk_full:
-					print("OSError reported. Disk may be full - will try again - clear space")
+					print("OSError reported. Invalid disk or the disk may be full - will try again - clear space")
 					pass
 				else:
 					raise
 
 			time.sleep(sleep_time)
 
 		if len(self.failed_tasks) > 0:
-			message = f"{len(self.failed_tasks)} images failed to export. Example error message from first" \
+			message = f"{len(self.failed_tasks)} image(s) failed to export. Example error message from first" \
 								f" failed image \"{self.failed_tasks[0].last_task_status['description']}\" was" \
 								f" \"{self.failed_tasks[0].last_task_status['error_message']}\"." \
 								f" Check https://code.earthengine.google.com/tasks in your web browser to see status and" \
@@ -370,7 +373,7 @@ def export(self,
 			clip (Optional[ee.geometry.Geometry]): Defines the region of interest for export - does not perform a strict clip, which is often slower.
 				Instead, it uses the Earth Engine export's "region" parameter to clip the results to the bounding box of
 				the clip geometry. To clip to the actual geometry, set strict_clip to True.
-			strict_clip (Optional[bool]: When set to True, performs a true clip on the result so that it's not just the bounding box but also the
+			strict_clip (Optional[bool]): When set to True, performs a true clip on the result so that it's not just the bounding box but also the
 				actual clipping geometry. Defaults to False.
 			drive_root_folder (Optional[Union[str, Path]]): The folder for exporting if "drive" is selected.
 
@@ -544,12 +547,11 @@ def zonal_stats(self,
 					report_threshold: int = 1000,
 					write_batch_size: int = 2000,
 					use_points: bool = False,
-					inject_constants: dict = dict(),
+					inject_constants: Optional[dict] = None,
 					nodata_value: int = -9999,
 					all_touched: bool = False
 					) -> None:
 		"""
-
 		Args:
 			polygons (Union[str, Path]):
 			keep_fields (tuple[str, ...]):
@@ -558,10 +560,15 @@ def zonal_stats(self,
 				Set to None to disable.
 			write_batch_size (int): How many zones should we store up before writing to the disk? Defaults to 2000.
 			use_points (bool):
+			inject_constants(Optional[dict]):
+			nodata_value (int):
+			all_touched (bool):
 
 		Returns:
 			None
 		"""
+		if inject_constants is None:
+			inject_constants = dict()
 
 		self.zonal_output_filepath = zonal.zonal_stats(
 							polygons,
@@ -580,7 +587,7 @@ def zonal_stats(self,
 
 	def _check_task_status(self) -> Dict[str, Union[Dict[str, str], bool]]:
 		"""
-		Updates the status is it needs to be changed
+		Updates the status if it needs to be changed
 
 		Returns:
 			Dict[str, Union[Dict[str, str], bool]]: Returns a dictionary of the most up-to-date status and whether that status was changed

eedl/mosaic_rasters.py

@@ -3,7 +3,6 @@
 import tempfile
 from pathlib import Path
 from typing import Sequence, Union
-
 from osgeo import gdal
 
 
@@ -21,7 +20,7 @@ def mosaic_folder(folder_path: Union[str, Path], output_path: Union[str, Path],
 	"""
 	tifs = [os.path.join(folder_path, filename) for filename in os.listdir(folder_path) if filename.endswith(".tif") and filename.startswith(prefix)]
 
-	if len(tifs) == 1:  # If we only got one image back, don't both mosaicking, though this will also skip generating overviews.
+	if len(tifs) == 1:  # If we only got one image back, don't bother mosaicking, though this will also skip generating overviews.
 		shutil.move(tifs[0], output_path)  # Just move the output image to the "mosaic" name, then return.
 		return
 
@@ -44,7 +43,7 @@ def mosaic_rasters(raster_paths: Sequence[Union[str, Path]],
 	"""
 
 	# gdal.SetConfigOption("GTIFF_SRC_SOURCE", "GEOKEYS")
-	vrt_path = tempfile.mktemp(suffix=".vrt", prefix="mosaic_rasters_")
+	vrt_path = tempfile.mkstemp(suffix=".vrt", prefix="mosaic_rasters_")
 
 	vrt_options = gdal.BuildVRTOptions(resampleAlg='nearest', resolution="highest")
 	my_vrt = gdal.BuildVRT(vrt_path, raster_paths, options=vrt_options)

examples/basic.py

@@ -1,10 +1,8 @@
 import ee
 from ee import ImageCollection
 
-# we should change the name of our Image class - it conflicts with the class image in the ee package, and people will
-# likely be using both. Let's not cause confusion
-from eedl.image import EEDLImage
 import eedl
+from eedl.image import EEDLImage
 
 
 def test_simple() -> None:
@@ -14,7 +12,7 @@ def test_simple() -> None:
 	# Adam, make sure to set the drive root folder for your own testing - we'll need to fix this, and in the future,
 	# we can use a Google Cloud bucket for most testing this is clunky - we should make the instantiation of the image be able to take a kwarg that sets the value of image, I think.
 	image = EEDLImage()
-	image.export(s2_image, "valley_water_s2_test_image", export_type="Drive", drive_root_folder=r"G:\My Drive", clip=geometry)
+	image.export(s2_image, "valley_water_s2_test_image", export_type="Drive", clip=geometry, drive_root_folder=r"G:\My Drive")
 
 	# We need to make it check and report whether the export on the EE side was successful. This test "passed" because Earth Engine failed and there wasn't anything to download (oops)
 	# Adam, make sure to set the folder you want results to be downloaded to

examples/get_gridmet_eto.py

@@ -4,10 +4,10 @@
 ee.Initialize()
 
 
-def get_days(month, year):
+def get_days(input_month: str, input_year: int) -> int:
 	days = {
 		'01': 31,
-		'02': 28 if not year == 2020 else 29,
+		'02': 28 if not input_year == 2020 else 29,
 		'03': 31,
 		'04': 30,
 		'05': 31,
@@ -20,7 +20,7 @@ def get_days(month, year):
 		'12': 31
 	}
 
-	return days[month]
+	return days[input_month]
 
 
 years = (2019, 2020, 2021)

examples/scv_et_rework.py

@@ -3,15 +3,13 @@
 import ee
 from ee import ImageCollection
 
-# we should change the name of our Image class - it conflicts with the class image in the ee package, and people will
-# likely be using both. Let's not cause confusion
 from eedl.image import EEDLImage
 import eedl
 
 ee.Initialize()
 
 
-def scv_data_download_for_year(year, openet_collection=r"OpenET/ENSEMBLE/CONUS/GRIDMET/MONTHLY/v2_0", band="et_ensemble_mad") -> Iterable:
+def scv_data_download_for_year(year: str, openet_collection: str = r"OpenET/ENSEMBLE/CONUS/GRIDMET/MONTHLY/v2_0", band: str = "et_ensemble_mad") -> Iterable[EEDLImage, EEDLImage]:
 	geometry = ee.FeatureCollection("users/nrsantos/vw_extraction_mask").geometry()
 
 	# so, we need two images per year - one is for all months, the other is for just the winter months
@@ -52,7 +50,7 @@ def scv_data_download_for_year(year, openet_collection=r"OpenET/ENSEMBLE/CONUS/G
 								folder="vw_et_update_2023"
 							)
 
-	return (annual_export_image, winter_export_image)
+	return annual_export_image, winter_export_image
 	# return (annual_export_image, )
 
 
@@ -64,8 +62,9 @@ def scv_data_download_for_year(year, openet_collection=r"OpenET/ENSEMBLE/CONUS/G
 							}
 
 
-def download_updated_vw_et_images_by_year(download_folder=r"D:\vw_et_update_2023",
-											field_boundaries=field_boundaries_by_year) -> None:
+def download_updated_vw_et_images_by_year(download_folder: str = r"D:\vw_et_update_2023",
+											field_boundaries: dict[str: str] = field_boundaries_by_year) -> None:
+
 	exports_by_year = {}
 
 	print("Running exports")

setup.cfg

@@ -7,7 +7,7 @@ long_description_content_type=text/markdown
 long_description=file: README.md
 platforms = unix, linux, osx, cygwin, win32
 url = https://github.com/water3d/eedl
-version = 0.2023.10.18
+version = 0.2023.11.13
 classifiers =
     Programming Language :: Python :: 3
     Programming Language :: Python :: 3 :: Only