From 43aff3568f975f5adbf8c7518ba75ab93949f4eb Mon Sep 17 00:00:00 2001 From: Cal Corum Date: Mon, 30 Mar 2026 07:53:58 -0500 Subject: [PATCH] fix: increase API timeouts to prevent bulk query failures db_calls.py default timeouts raised from 3s to 30s across all methods (db_get, url_get, db_patch, db_post, db_put). scouting_batters.py fetch_data now passes timeout=120 for large card rating queries. Co-Authored-By: Claude Opus 4.6 (1M context) --- db_calls.py | 10 +++++----- scouting_batters.py | 2 +- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/db_calls.py b/db_calls.py index ff31a53..faf2cc0 100644 --- a/db_calls.py +++ b/db_calls.py @@ -61,7 +61,7 @@ async def db_get( object_id: int = None, params: list = None, none_okay: bool = True, - timeout: int = 3, + timeout: int = 30, ) -> Optional[dict]: req_url = get_req_url(endpoint, api_ver=api_ver, object_id=object_id, params=params) log_string = f"get:\n{endpoint} id: {object_id} params: {params}" @@ -86,7 +86,7 @@ async def db_get( raise ValueError(f"DB: {e}") -async def url_get(url: str, timeout: int = 3) -> dict: +async def url_get(url: str, timeout: int = 30) -> dict: log_string = f"get:\n{url}" logger.info(log_string) if master_debug else logger.debug(log_string) @@ -105,7 +105,7 @@ async def url_get(url: str, timeout: int = 3) -> dict: async def db_patch( - endpoint: str, object_id: int, params: list, api_ver: int = 2, timeout: int = 3 + endpoint: str, object_id: int, params: list, api_ver: int = 2, timeout: int = 30 ) -> dict: req_url = get_req_url(endpoint, api_ver=api_ver, object_id=object_id, params=params) log_string = f"patch:\n{endpoint} {params}" @@ -126,7 +126,7 @@ async def db_patch( async def db_post( - endpoint: str, api_ver: int = 2, payload: dict = None, timeout: int = 3 + endpoint: str, api_ver: int = 2, payload: dict = None, timeout: int = 30 ) -> dict: req_url = get_req_url(endpoint, api_ver=api_ver) log_string = f"post:\n{endpoint} payload: {payload}\ntype: {type(payload)}" @@ -147,7 +147,7 @@ async def db_post( async def db_put( - endpoint: str, api_ver: int = 2, payload: dict = None, timeout: int = 3 + endpoint: str, api_ver: int = 2, payload: dict = None, timeout: int = 30 ) -> dict: req_url = get_req_url(endpoint, api_ver=api_ver) log_string = f"put:\n{endpoint} payload: {payload}\ntype: {type(payload)}" diff --git a/scouting_batters.py b/scouting_batters.py index ac9222e..7bb6e90 100644 --- a/scouting_batters.py +++ b/scouting_batters.py @@ -96,7 +96,7 @@ def build_c_throw(all_positions, pos_code): async def fetch_data(data): start_time = log_time("start", print_to_console=False) - this_query = await db_get(endpoint=data[0], params=data[1]) + this_query = await db_get(endpoint=data[0], params=data[1], timeout=120) log_time("end", print_to_console=False, start_time=start_time) return this_query