Beam analysis endpoint

README.md

@@ -217,6 +217,36 @@ suggested_radius = phq.radius.search(location__origin="45.5051,-122.6750")
 print(suggested_radius.radius, suggested_radius.radius_unit, suggested_radius.location.model_dump(exclude_none=True))
 ```
 
+### Beam endpoints
+
+Get Analysis.
+
+Additional examples are available in [usecases/beam/analysis](https://github.com/predicthq/sdk-py/tree/master/usecases/beam/analysis) folder.
+
+```Python
+from predicthq import Client
+
+phq = Client(access_token="abc123")
+
+
+analysis = phq.beam.analysis.get(analysis_id="abc123")
+print(analysis.model_dump(exclude_none=True))
+```
+
+Get Analysis Group.
+
+Additional examples are available in [usecases/beam/analysis_group](https://github.com/predicthq/sdk-py/tree/master/usecases/beam/analysis_group) folder.
+
+```Python
+from predicthq import Client
+
+phq = Client(access_token="abc123")
+
+
+analysis_group = phq.beam.analysis_group.get(group_id="abc123")
+print(analysis_group.model_dump(exlcude_none=True))
+```
+
 ### Serializing search results into a dictionary
 
 All search results can be serialized into a dictionary using the `.model_dump()` method call.

predicthq/client.py

@@ -16,7 +16,7 @@ class Client(object):
     @classmethod
     def build_url(cls, path):
         result = list(urlparse(path))
-        result[2] = f"/{result[2].strip('/')}/"
+        result[2] = f"/{result[2].strip('/')}"
         return urljoin(config.ENDPOINT_URL, urlunparse(result))
 
     def __init__(self, access_token=None):
@@ -35,6 +35,7 @@ def initialize_endpoints(self):
         self.accounts = endpoints.AccountsEndpoint(proxy(self))
         self.places = endpoints.PlacesEndpoint(proxy(self))
         self.radius = endpoints.SuggestedRadiusEndpoint(proxy(self))
+        self.beam = endpoints.BeamEndpoint(proxy(self))
 
     def get_headers(self, headers):
         _headers = {

predicthq/endpoints/__init__.py

@@ -5,6 +5,7 @@
 from .v1.features import FeaturesEndpoint
 from .v1.places import PlacesEndpoint
 from .v1.radius import SuggestedRadiusEndpoint
+from .v1.beam import BeamEndpoint
 
 
 __all__ = [
@@ -15,4 +16,5 @@
     "FeaturesEndpoint",
     "PlacesEndpoint",
     "SuggestedRadiusEndpoint",
+    "BeamEndpoint",
 ]

predicthq/endpoints/decorators.py

@@ -4,6 +4,8 @@
 
 from predicthq.exceptions import ValidationError
 
+from predicthq.endpoints.schemas import ArgKwargResultSet
+
 
 def _kwargs_to_key_list_mapping(kwargs, separator="__"):
     """
@@ -41,7 +43,7 @@ def _to_url_params(key_list_mapping, glue=".", separator=",", parent_key=""):
     return params
 
 
-def _to_json(key_list_mapping, json = None):
+def _to_json(key_list_mapping, json=None):
     """
     Converts key_list_mapping to json
     """
@@ -81,14 +83,16 @@ def returns(model_class):
     def decorator(f):
         @functools.wraps(f)
         def wrapper(endpoint, *args, **kwargs):
-
             model = getattr(endpoint.Meta, f.__name__, {}).get("returns", model_class)
 
             data = f(endpoint, *args, **kwargs)
             try:
                 loaded_model = model(**data)
                 loaded_model._more = functools.partial(wrapper, endpoint)
                 loaded_model._endpoint = endpoint
+                if isinstance(loaded_model, ArgKwargResultSet):
+                    loaded_model._args = args
+                    loaded_model._kwargs = kwargs
                 return loaded_model
             except PydanticValidationError as e:
                 raise ValidationError(e)

predicthq/endpoints/schemas.py

@@ -1,4 +1,3 @@
-from urllib.parse import parse_qsl, urlparse
 from typing import Callable, Optional
 
 from pydantic import BaseModel, HttpUrl
@@ -59,3 +58,8 @@ def iter_all(self):
 
     def __iter__(self):
         return self.iter_items()
+
+
+class ArgKwargResultSet(ResultSet):
+    _args: Optional[dict] = None
+    _kwargs: Optional[dict] = None

predicthq/endpoints/v1/beam/__init__.py

@@ -0,0 +1,5 @@
+from .endpoint import BeamEndpoint
+from .schemas import Analysis, AnalysisGroup
+
+
+__all__ = ["BeamEndpoint", "Analysis", "AnalysisGroup"]