summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDanglewood <85772166+deeleeramone@users.noreply.github.com>2024-05-01 10:43:18 -0700
committerDanglewood <85772166+deeleeramone@users.noreply.github.com>2024-05-01 10:43:18 -0700
commit6d8b924823bd0660c0b22617fc260030ce526dc9 (patch)
tree9b71ea4f9af0426c8f74a43b363a90e1654c254c
parente37c0c0a4024de9a9f79c7edefcabbd3145bfe87 (diff)
return error message when invalid request
-rw-r--r--openbb_platform/providers/intrinio/openbb_intrinio/models/equity_historical.py12
1 files changed, 9 insertions, 3 deletions
diff --git a/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_historical.py b/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_historical.py
index ff5f0893258..f1f30c29dc3 100644
--- a/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_historical.py
+++ b/openbb_platform/providers/intrinio/openbb_intrinio/models/equity_historical.py
@@ -15,10 +15,11 @@ from openbb_core.provider.utils.descriptions import (
DATA_DESCRIPTIONS,
QUERY_DESCRIPTIONS,
)
+from openbb_core.provider.utils.errors import EmptyDataError
from openbb_core.provider.utils.helpers import (
ClientResponse,
ClientSession,
- amake_requests,
+ amake_request,
get_querystring,
)
from pydantic import Field, PrivateAttr, model_validator
@@ -195,7 +196,6 @@ class IntrinioEquityHistoricalFetcher(
) -> List[Dict]:
"""Return the raw data from the Intrinio endpoint."""
api_key = credentials.get("intrinio_api_key") if credentials else ""
-
base_url = f"https://api-v2.intrinio.com/securities/{query.symbol}/prices"
query_str = get_querystring(
query.model_dump(by_alias=True), ["symbol", "interval"]
@@ -211,6 +211,10 @@ class IntrinioEquityHistoricalFetcher(
async def callback(response: ClientResponse, session: ClientSession) -> list:
"""Return the response."""
init_response = await response.json()
+ if "error" in init_response:
+ raise RuntimeError(
+ f"Intrinio Error Message -> {init_response['error']}: {init_response.get('message')}"
+ )
all_data: list = init_response.get(data_key, [])
@@ -226,7 +230,7 @@ class IntrinioEquityHistoricalFetcher(
url = f"{base_url}&{query_str}&api_key={api_key}"
- return await amake_requests([url], callback, **kwargs)
+ return await amake_request(url, response_callback=callback, **kwargs)
@staticmethod
def transform_data(
@@ -235,6 +239,8 @@ class IntrinioEquityHistoricalFetcher(
**kwargs: Any,
) -> List[IntrinioEquityHistoricalData]:
"""Return the transformed data."""
+ if not data:
+ raise EmptyDataError("The request was returned empty.")
date_col = (
"time"
if query.interval in ["1m", "5m", "10m", "15m", "30m", "60m", "1h"]