icdSrSSKJr SSKJr SSKrSSKJr SSKJ r \"\ 5r "SS5r g) zClient for tab-api-ingest service. Provides async HTTP client for consuming racing data from the tab-api-ingest REST API instead of calling the TAB Affiliates API directly. ) annotations)AnyN) get_logger) get_settingsc\rSrSrSrS SSjjrSrSrS SSjjrSSSjjr SS jr SS jr SSS jjr S r g)IngestServiceClientaAsync HTTP client for tab-api-ingest REST API. Fetches meetings, races, and runner data from the tab-api-ingest service which sources data from the TAB/HRNZ APIs and stores it in its own DB. Example: >>> async with IngestServiceClient() as client: >>> meetings = await client.get_meetings(date="2024-01-01") >>> for meeting in meetings: >>> races = await client.get_races(meeting_id=meeting["meeting"]) Nc[5nU=(d3 [USS5=(a URR=(d SUlSUlg)zInitialize the ingest service client. Args: base_url: tab-api-ingest service base URL. Defaults to the INGEST_SERVICE_URL setting or http://localhost:9090. ingest_serviceNzhttp://localhost:9090)rgetattrr urlbase_url_client)selfrsettingss B/root/tipsharks/tipsharks-elo-api/packages/ingest_client/client.py__init__IngestServiceClient.__init__ sN >  'x!148,''++ '' 26 c@# [R"SS9UlU$7f)u8Async context manager entry — creates the HTTP client.>@timeout)httpx AsyncClientr)rs r __aenter__IngestServiceClient.__aenter__0s((6  sc~# URb*URR5IShvN SUlggN 7f)u6Async context manager exit — closes the HTTP client.N)raclose)rexc_typeexc_valexc_tbs r __aexit__IngestServiceClient.__aexit__5s4 << #,,%%' ' 'DL $ 's +=;=c# URc[R"SS9UlURRXUS9IShvN nUR 5 UR 5$N$7f)zMake an HTTP request with the internal client. Args: method: HTTP method url: Full URL params: Query parameters Returns: Response JSON data Raises: httpx.HTTPError: On request failure Nrr)params)rrrrequestraise_for_statusjson)rmethodr r&responses r_requestIngestServiceClient._request;s]& <<  ,,T:DL--f&-II!!#}}JsAA-A+%A-c# 0nU(aXS'U(aX$S'U(aX4S'[RSSU0S9 URSURS3U5IS hvN n[RS [ U5S 35 U$N(7f) zFetch meetings from the ingest service. Args: date: Optional ISO date filter (YYYY-MM-DD) country: Optional country code filter (e.g. NZ, AUS) category: Optional racing category (T, H, G) Returns: List of meeting data dictionaries datecountrycategoryz%Fetching meetings from ingest servicer&extraGETz /api/meetingsNzFound z meetings from ingest service)loggerinfor,rlen)rr/r0r1r&datas r get_meetings IngestServiceClient.get_meetingsTs "$ !6N  '9  !):  3V$  ]]5T]]O=*I6RR fSYK'DEF SsAB B )B c# [RSUS35 URSURSU35IShvN $N7f)z{Fetch a single race from the ingest service. Args: race_id: Race/event ID (string) Returns: Race data dictionary zFetching race  from ingest servicer4 /api/races/Nr5r6r,rrrace_ids rget_raceIngestServiceClient.get_raceusC  nWI-ABC]]5T]]O;wi*PQQQQs>AAAc# [RSUS35 URSURSUS35IShvN $N7f)zFetch runners for a race from the ingest service. Args: race_id: Race/event ID (string) Returns: List of runner data dictionaries zFetching runners for race r<r4r=z/runnersNr>r?s r get_runnersIngestServiceClient.get_runnerssP  0 9MNO]] }}o[  :    s?AAAc# XES.nU(aXS'U(aX&S'U(aX6S'[RSSU0S9 URSURS 3U5IS hvN $N7f) a*Fetch races from the ingest service. Args: date: Optional ISO date filter (YYYY-MM-DD) meeting_id: Optional meeting ID filter status: Optional status filter limit: Maximum results (default 100) offset: Pagination offset (default 0) Returns: List of race data dictionaries )limitoffsetr/ meetingIdstatusz"Fetching races from ingest servicer&r2r4z /api/racesNr>)rr/ meeting_idrJrGrHr&s r get_racesIngestServiceClient.get_racessq(,1!C !6N ",;  %8  0V$  ]]5T]]O:*FOOOOsAA(!A&"A()rr)N)r str | None)r*strr rOr&zdict[str, Any] | Nonereturnr)NNN)r/rNr0rNr1rNrPlist[dict[str, Any]])r@rOrPzdict[str, Any])r@rOrPrQ)NNNdr) r/rNrKrNrJrNrGintrHrSrPrQ)__name__ __module__ __qualname____firstlineno____doc__rrr#r,r9rArDrL__static_attributes__rrrrs 6   )- &  6 "#    B R  " !%! !P!P!P !P  !P  !P !P!Prr) rX __future__rtypingrrpackages.core.common.loggingrpackages.core.common.settingsrrTr5rrZrrr_s3 # 36 H ^P^Pr