Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/gfwapiclient/base/models.py
Original file line number Diff line number Diff line change
Expand Up @@ -347,7 +347,7 @@ def from_file_or_geojson(
cls,
*,
source: Union[str, Path, Dict[str, Any], SupportsGeoJsonInterface],
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> Self:
"""Create a `GeoJson` instance from a spatial data source.

Expand Down
18 changes: 9 additions & 9 deletions src/gfwapiclient/resources/bulk_downloads/resources.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

import pydantic

from gfwapiclient.base.models import GeoJson, Geometry, SupportsGeoJsonInterface
from gfwapiclient.base.models import GeoJson, Geometry, Region, SupportsGeoJsonInterface
from gfwapiclient.exceptions import (
RequestBodyValidationError,
RequestParamsValidationError,
Expand Down Expand Up @@ -97,9 +97,9 @@ async def create_bulk_report(
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
format: Optional[Union[BulkReportFormat, str]] = None,
region: Optional[Union[BulkReportRegion, Dict[str, Any]]] = None,
region: Optional[Union[BulkReportRegion, Region, Dict[str, Any]]] = None,
filters: Optional[List[str]] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> BulkReportCreateResult:
"""Create a bulk report based on specified filters and spatial parameters.

Expand Down Expand Up @@ -141,7 +141,7 @@ async def create_bulk_report(
Allowed values: `"JSON"`, `"CSV"`.
Example: `"JSON"`.

region (Optional[Union[BulkReportRegion, Dict[str, Any]]], default=None):
region (Optional[Union[BulkReportRegion, Region, Dict[str, Any]]], default=None):
Predefined region information to filter the bulk report.
Defaults to `None`.
Example: `{"dataset": "public-eez-areas", "id": 8466}`.
Expand Down Expand Up @@ -242,7 +242,7 @@ async def get_all_bulk_reports(
offset: Optional[int] = None,
sort: Optional[str] = None,
status: Optional[Union[BulkReportStatus, str]] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> BulkReportListResult:
"""Get all bulk reports created by user or application.

Expand Down Expand Up @@ -314,7 +314,7 @@ async def get_bulk_report_file_download_url(
*,
id: str,
file: Optional[Union[BulkReportFileType, str]] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> BulkReportFileResult:
"""Get signed URL to download file of the previously created bulk report.

Expand Down Expand Up @@ -377,7 +377,7 @@ async def query_bulk_fixed_infrastructure_data_report(
offset: Optional[int] = None,
sort: Optional[str] = None,
includes: Optional[List[str]] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> BulkFixedInfrastructureDataQueryResult:
"""Get bulk fixed infrastructure data report in JSON Format.

Expand Down Expand Up @@ -465,7 +465,7 @@ def _prepare_create_bulk_report_request_body(
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
format: Optional[Union[BulkReportFormat, str]] = None,
region: Optional[Union[BulkReportRegion, Dict[str, Any]]] = None,
region: Optional[Union[BulkReportRegion, Region, Dict[str, Any]]] = None,
filters: Optional[List[str]] = None,
) -> BulkReportCreateBody:
"""Prepare and return create a bulk report request body."""
Expand All @@ -481,7 +481,7 @@ def _prepare_create_bulk_report_request_body(
"dataset": _dataset,
"geojson": _geojson,
"format": format or BulkReportFormat.JSON,
"region": region or None,
"region": region.model_dump() if isinstance(region, Region) else region,
"filters": filters or None,
}
request_body: BulkReportCreateBody = BulkReportCreateBody(**_request_body)
Expand Down
2 changes: 1 addition & 1 deletion src/gfwapiclient/resources/datasets/resources.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ async def get_sar_fixed_infrastructure(
geometry: Optional[
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> SARFixedInfrastructureResult:
"""Get SAR (Synthetic-aperture radar) fixed infrastructure data.

Expand Down
24 changes: 12 additions & 12 deletions src/gfwapiclient/resources/events/resources.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@

import pydantic

from gfwapiclient.base.models import GeoJson, Geometry, SupportsGeoJsonInterface
from gfwapiclient.base.models import GeoJson, Geometry, Region, SupportsGeoJsonInterface
from gfwapiclient.exceptions.validation import (
RequestBodyValidationError,
RequestParamsValidationError,
Expand Down Expand Up @@ -72,11 +72,11 @@ async def get_all_events(
geometry: Optional[
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
region: Optional[Union[EventRegion, Dict[str, Any]]] = None,
region: Optional[Union[EventRegion, Region, Dict[str, Any]]] = None,
limit: Optional[int] = None,
offset: Optional[int] = None,
sort: Optional[str] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> EventListResult:
"""Get All Events.

Expand Down Expand Up @@ -146,7 +146,7 @@ async def get_all_events(
(e.g., JSON string or dictionary) or `GeoJson` model instance. Defaults to `None`.
Example: `{"type": "Polygon", "coordinates": [...]}`, or `/path/to/your/custom/region.shp`.

region (Optional[Union[EventRegion, Dict[str, Any]]], default=None):
region (Optional[Union[EventRegion, Region, Dict[str, Any]]], default=None):
Region to filter events. Defaults to `None`.
Example: `{"dataset": "public-eez-areas", "id": "5690"}`.

Expand Down Expand Up @@ -215,7 +215,7 @@ async def get_event_by_id(
*,
id: str,
dataset: Union[EventDataset, str],
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> EventDetailResult:
"""Get one by Event ID.

Expand Down Expand Up @@ -278,9 +278,9 @@ async def get_events_stats(
geometry: Optional[
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
region: Optional[Union[EventRegion, Dict[str, Any]]] = None,
region: Optional[Union[EventRegion, Region, Dict[str, Any]]] = None,
includes: Optional[Union[List[EventStatsInclude], List[str]]] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> EventStatsResult:
"""Get events statistics worldwide or for a specific region.

Expand Down Expand Up @@ -353,7 +353,7 @@ async def get_events_stats(
(e.g., JSON string or dictionary) or `GeoJson` model instance. Defaults to `None`.
Example: `{"type": "Polygon", "coordinates": [...]}`, or `/path/to/your/custom/region.shp`.

region (Optional[Union[EventRegion, Dict[str, Any]]], default=None):
region (Optional[Union[EventRegion, Region, Dict[str, Any]]], default=None):
Region to filter statistics. Defaults to `None`.
Example: `{"dataset": "public-eez-areas", "id": "5690"}`.

Expand Down Expand Up @@ -442,7 +442,7 @@ def _prepare_get_all_events_request_body(
geometry: Optional[
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
region: Optional[Union[EventRegion, Dict[str, Any]]] = None,
region: Optional[Union[EventRegion, Region, Dict[str, Any]]] = None,
) -> EventListBody:
"""Prepares and returns the request body for the get all events endpoint."""
try:
Expand All @@ -462,7 +462,7 @@ def _prepare_get_all_events_request_body(
"vessel_groups": vessel_groups,
"flags": flags,
"geometry": _geometry,
"region": region,
"region": region.model_dump() if isinstance(region, Region) else region,
}
request_body: EventListBody = EventListBody(**_request_body)
except pydantic.ValidationError as exc:
Expand Down Expand Up @@ -508,7 +508,7 @@ def _prepare_get_events_stats_request_body(
geometry: Optional[
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
region: Optional[Union[EventRegion, Dict[str, Any]]] = None,
region: Optional[Union[EventRegion, Region, Dict[str, Any]]] = None,
includes: Optional[Union[List[EventStatsInclude], List[str]]] = None,
) -> EventStatsBody:
"""Prepares and returns the request body for the get events statistics endpoint."""
Expand All @@ -530,7 +530,7 @@ def _prepare_get_events_stats_request_body(
"vessel_groups": vessel_groups,
"flags": flags,
"geometry": _geometry,
"region": region,
"region": region.model_dump() if isinstance(region, Region) else region,
"includes": includes,
}
request_body: EventStatsBody = EventStatsBody(**_request_body)
Expand Down
30 changes: 15 additions & 15 deletions src/gfwapiclient/resources/fourwings/resources.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@

import pydantic

from gfwapiclient.base.models import GeoJson, SupportsGeoJsonInterface
from gfwapiclient.base.models import GeoJson, Region, SupportsGeoJsonInterface
from gfwapiclient.exceptions import (
RequestBodyValidationError,
RequestParamsValidationError,
Expand Down Expand Up @@ -75,8 +75,8 @@ async def create_fishing_effort_report(
geojson: Optional[
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
region: Optional[Union[FourWingsReportRegion, Dict[str, Any]]] = None,
**kwargs: Dict[str, Any],
region: Optional[Union[FourWingsReportRegion, Region, Dict[str, Any]]] = None,
**kwargs: Any,
) -> FourWingsReportResult:
"""Create 4Wings AIS apparent fishing effort report for a specified region.

Expand Down Expand Up @@ -144,7 +144,7 @@ async def create_fishing_effort_report(
(e.g., JSON string or dictionary) or `GeoJson` model instance. Defaults to `None`.
Example: `{"type": "Polygon", "coordinates": [...]}`, or `/path/to/your/custom/region.shp`.

region (Optional[Union[FourWingsReportRegion, Dict[str, Any]]], default=None):
region (Optional[Union[FourWingsReportRegion, Region, Dict[str, Any]]], default=None):
Predefined region information to filter the report. Defaults to `None`.
Example: `{"dataset": "public-eez-areas", "id": "5690"}`.

Expand Down Expand Up @@ -198,8 +198,8 @@ async def create_ais_presence_report(
geojson: Optional[
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
region: Optional[Union[FourWingsReportRegion, Dict[str, Any]]] = None,
**kwargs: Dict[str, Any],
region: Optional[Union[FourWingsReportRegion, Region, Dict[str, Any]]] = None,
**kwargs: Any,
) -> FourWingsReportResult:
"""Create 4Wings AIS vessel presence report for a specified region.

Expand Down Expand Up @@ -267,7 +267,7 @@ async def create_ais_presence_report(
(e.g., JSON string or dictionary) or `GeoJson` model instance. Defaults to `None`.
Example: `{"type": "Polygon", "coordinates": [...]}`, or `/path/to/your/custom/region.shp`.

region (Optional[Union[FourWingsReportRegion, Dict[str, Any]]], default=None):
region (Optional[Union[FourWingsReportRegion, Region, Dict[str, Any]]], default=None):
Predefined region information to filter the report. Defaults to `None`.
Example: `{"dataset": "public-eez-areas", "id": "5690"}`.

Expand Down Expand Up @@ -321,8 +321,8 @@ async def create_sar_presence_report(
geojson: Optional[
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
region: Optional[Union[FourWingsReportRegion, Dict[str, Any]]] = None,
**kwargs: Dict[str, Any],
region: Optional[Union[FourWingsReportRegion, Region, Dict[str, Any]]] = None,
**kwargs: Any,
) -> FourWingsReportResult:
"""Create 4Wings SAR vessel detections report for a specified region.

Expand Down Expand Up @@ -389,7 +389,7 @@ async def create_sar_presence_report(
(e.g., JSON string or dictionary) or `GeoJson` model instance. Defaults to `None`.
Example: `{"type": "Polygon", "coordinates": [...]}`, or `/path/to/your/custom/region.shp`.

region (Optional[Union[FourWingsReportRegion, Dict[str, Any]]], default=None):
region (Optional[Union[FourWingsReportRegion, Region, Dict[str, Any]]], default=None):
Predefined region information to filter the report. Defaults to `None`.
Example: `{"dataset": "public-eez-areas", "id": "5690"}`.

Expand Down Expand Up @@ -445,8 +445,8 @@ async def create_report(
geojson: Optional[
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
region: Optional[Union[FourWingsReportRegion, Dict[str, Any]]] = None,
**kwargs: Dict[str, Any],
region: Optional[Union[FourWingsReportRegion, Region, Dict[str, Any]]] = None,
**kwargs: Any,
) -> FourWingsReportResult:
"""Create 4Wings report for a specified region.

Expand Down Expand Up @@ -540,7 +540,7 @@ async def create_report(
(e.g., JSON string or dictionary) or `GeoJson` model instance. Defaults to `None`.
Example: `{"type": "Polygon", "coordinates": [...]}`, or `/path/to/your/custom/region.shp`.

region (Optional[Union[FourWingsReportRegion, Dict[str, Any]]], default=None):
region (Optional[Union[FourWingsReportRegion, Region, Dict[str, Any]]], default=None):
Predefined region information to filter the report. Defaults to `None`.
Example: `{"dataset": "public-eez-areas", "id": "5690"}`.

Expand Down Expand Up @@ -594,7 +594,7 @@ def _prepare_create_report_request_body(
geojson: Optional[
Union[GeoJson, str, Path, Dict[str, Any], SupportsGeoJsonInterface]
] = None,
region: Optional[Union[FourWingsReportRegion, Dict[str, Any]]] = None,
region: Optional[Union[FourWingsReportRegion, Region, Dict[str, Any]]] = None,
) -> FourWingsReportBody:
"""Prepare request body for the 4Wings report endpoint."""
try:
Expand All @@ -603,7 +603,7 @@ def _prepare_create_report_request_body(
)
_request_body: Dict[str, Any] = {
"geojson": _geojson,
"region": region,
"region": region.model_dump() if isinstance(region, Region) else region,
}
request_body: FourWingsReportBody = FourWingsReportBody(**_request_body)
except pydantic.ValidationError as exc:
Expand Down
4 changes: 2 additions & 2 deletions src/gfwapiclient/resources/insights/resources.py
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ async def get_vessel_insights(
vessels: Union[
List[VesselInsightDatasetVessel], List[Dict[str, Any]], List[str]
],
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> VesselInsightResult:
"""Get insights for one or several vessels.

Expand Down Expand Up @@ -163,7 +163,7 @@ def _prepare_get_vessel_insights_request_body(
vessels: Union[
List[VesselInsightDatasetVessel], List[Dict[str, Any]], List[str]
],
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> VesselInsightBody:
"""Prepare and returns get vessel insights request body."""
try:
Expand Down
6 changes: 3 additions & 3 deletions src/gfwapiclient/resources/references/resources.py
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ async def get_eez_regions(
Union[str, Pattern[str], List[str], List[Pattern[str]]]
] = None,
predicate: Optional[Callable[[EEZRegionItem], bool]] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> EEZRegionResult:
"""Get available Exclusive Economic Zone (EEZ) regions data.

Expand Down Expand Up @@ -178,7 +178,7 @@ async def get_mpa_regions(
id: Optional[Union[str, Pattern[str], List[str], List[Pattern[str]]]] = None,
label: Optional[Union[str, Pattern[str], List[str], List[Pattern[str]]]] = None,
predicate: Optional[Callable[[MPARegionItem], bool]] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> MPARegionResult:
"""Get available Marine Protected Area (MPA) regions data.

Expand Down Expand Up @@ -246,7 +246,7 @@ async def get_rfmo_regions(
id: Optional[Union[str, Pattern[str], List[str], List[Pattern[str]]]] = None,
label: Optional[Union[str, Pattern[str], List[str], List[Pattern[str]]]] = None,
predicate: Optional[Callable[[RFMORegionItem], bool]] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> RFMORegionResult:
"""Get available Regional Fisheries Management Organization (RFMO) regions data.

Expand Down
6 changes: 3 additions & 3 deletions src/gfwapiclient/resources/vessels/resources.py
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ async def search_vessels(
where: Optional[str] = None,
match_fields: Optional[Union[List[VesselMatchField], List[str]]] = None,
includes: Optional[Union[List[VesselSearchInclude], List[str]]] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> VesselSearchResult:
"""Search vessels based on provided parameters.

Expand Down Expand Up @@ -163,7 +163,7 @@ async def get_vessels_by_ids(
includes: Optional[List[VesselInclude]] = None,
match_fields: Optional[List[VesselMatchField]] = None,
vessel_groups: Optional[List[str]] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> VesselListResult:
"""Get a list of vessels by their IDs.

Expand Down Expand Up @@ -258,7 +258,7 @@ async def get_vessel_by_id(
registries_info_data: Optional[Union[VesselRegistryInfoData, str]] = None,
includes: Optional[Union[List[VesselInclude], List[str]]] = None,
match_fields: Optional[Union[List[VesselMatchField], List[str]]] = None,
**kwargs: Dict[str, Any],
**kwargs: Any,
) -> VesselDetailResult:
"""Get vessel details by ID.

Expand Down
Loading