_j5SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r J r J r J r SSKJr SSKJrJrJrJrJr SSKJr SSKJr "S S \5r"S S \5rg) ) annotationsN)DictAnyUnionOptional)Path)CreateImportParametersCreateImportResponseImportListImportsResponse UpdateImport)WebsetsBaseClient)WebsetsAsyncBaseClientc^\rSrSrSrU4SjrSS.SSjjrSSjrSSS.SS jjrSS jr SS jr S S S.SSjjr Sr U=r $) ImportsClientzClient for managing Imports.c$>[TU]U5 gNsuper__init__selfclient __class__s R/home/rurouni/.local/lib/python3.13/site-packages/exa_py/websets/imports/client.pyrImportsClient.__init__  Ncsv_datacJUGb[U[[45(aI[RR U5(a%[ USSS9nUR5nSSS5 O [U5n[U[5(a#URS5nURS5nO[USS5n[USS5nUbUc[WRS55n[R"[R "U55n[#U5n [%S[U 5S- 5n [U[5(aUR'5nUcXqS'UcXS'O4UR)5n UcX{S'UcXS'[*R,"U 5nUR/S US 9n [0R,"U 5n UcU $[2R4"U R6WS S 0S 9nUR95 URU R:5$!,(df  GN=fa^Create a new import to upload your data into Websets. Imports can be used to: - Enrich: Enhance your data with additional information using our AI-powered enrichment engine - Search: Query your data using Websets' agentic search with natural language filters - Exclude: Prevent duplicate or already known results from appearing in your searches Args: params (CreateImportParameters): The parameters for creating an import. csv_data (Union[str, Path], optional): CSV data to upload. Can be raw CSV string or file path. When provided, size and count will be automatically calculated if not specified in params. Returns: CreateImportResponse: If csv_data is None (traditional usage with upload URL). Import: If csv_data is provided (uploaded and processing). Nrzutf-8)encodingsizecountr /v0/imports)dataz Content-Typeztext/csv)r+headers) isinstancestrrospathisfileopenreaddictgetgetattrlenencodecsvreaderioStringIOlistmaxcopy model_dumpr model_validaterequestr requestsput upload_urlraise_for_statusid)rparamsr"f csv_content current_size current_countcalculated_size csv_readerrowscalculated_count params_dictresponseimport_responseupload_responses rcreateImportsClient.creates.  (S$K00RWW^^H5M5M(C':a"#&&(K;:"(m &$''%zz&1 & 7 3 &vvt< ' > #}'<"%k&8&8&A"B ZZ K(@A J'#&q#d)a-#8 fd++#[[]F#+)8v$,*:w"("3"3"5K#+.=F+$,/?G,3BB;OF<< F<;.==hG  " "",,  & &#Z0  ((*xx**++[;:s H H"cTURSU3SS9n[R"U5$)uGet a specific import. Args: import_id (str): The id of the Import. Returns: Import: The retrieved import. /v0/imports/GETmethodrBr rAr import_idrRs rr5ImportsClient.getes.<<,yk :5<I$$X..r cursorlimitcUUS.R5VVs0sH up4UcM X4_M nnnURSUSS9n[R"U5$s snnf)List all imports. Args: cursor (str, optional): The cursor to paginate through the results. limit (int, optional): The number of results to return (1-200, default 25). Returns: ListImportsResponse: List of imports with pagination info. rar*rZrHr\itemsrBr rArrbrckvrHrRs rr=ImportsClient.listqsu!eg  AD  << fU<K"11(;; s AAcVURSU3USS9n[R"U5$)Update an import configuration. Args: import_id (str): The id of the Import. params (UpdateImport): The parameters for updating an import. Returns: Import: The updated import. rYPATCHr+r\r]rr_rHrRs rupdateImportsClient.updates1<<,yk :PW<X$$X..r cTURSU3SS9n[R"U5$)nDelete an import. Args: import_id (str): The id of the Import. Returns: Import: The deleted import. rYDELETEr[r]r^s rdeleteImportsClient.deletes.<<,yk :8<L$$X..r timeout poll_intervalc[R"5nURU5nURS;aU$[R"5U- U:a[SUSUS35e[R"U5 Mi)Wait until an import is completed or failed. Args: import_id (str): The id of the Import. timeout (int, optional): Maximum time to wait in seconds. Defaults to 1800 (30 minutes). poll_interval (int, optional): Time to wait between polls in seconds. Defaults to 5. Returns: Import: The import once it's completed or failed. Raises: TimeoutError: If the import does not complete within the timeout period.  completedfailedImport  did not complete within  seconds)timer5status TimeoutErrorsleeprr_r|r} start_time import_objs rwait_until_completed"ImportsClient.wait_until_completedswYY[ ),J  $;;!!yy{Z''1"WYK7PQXPYYa#bcc JJ} %r rHz-Union[Dict[str, Any], CreateImportParameters]r"zOptional[Union[str, Path]]returnz#Union[CreateImportResponse, Import]r_r.rr rbz Optional[str]rcz Optional[int]rr r_r.rHz#Union[Dict[str, Any], UpdateImport]rr r_r.r|intr}rrr __name__ __module__ __qualname____firstlineno____doc__rrUr5r=rrrwr__static_attributes__ __classcell__rs@rrrse&!04 F,=F,- F, - F,P //34<* / /FJ`a&&r rc^\rSrSrSrU4SjrSS.SSjjrSSjrSSS.SS jjrSS jr SS jr S S S.SSjjr Sr U=r $)AsyncImportsClientz"Async client for managing Imports.c$>[TU]U5 grrrs rrAsyncImportsClient.__init__rr Nr!c# UGb[U[[45(aI[RR U5(a%[ USSS9nUR5nSSS5 O [U5n[U[5(a#URS5nURS5nO[USS5n[USS5nUbUc[WRS55n[R"[R "U55n[#U5n [%S[U 5S- 5n [U[5(aUR'5nUcXqS'UcXS'O4UR)5n UcX{S'UcXS'[*R,"U 5nUR/S US 9IShvN n [0R,"U 5n UcU $[2R4"5IShvN nUR7U R8WS S 0S 9IShvN nUR;5 SSS5IShvN URU R<5IShvN $!,(df  GN=fNNN]N?!,IShvN (df  NT=fN87fr$)r-r.rr/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@r rArBr httpx AsyncClientrDrErFrG)rrHr"rIrJrKrLrMrNrOrPrQrRrS http_clientrTs rrUAsyncImportsClient.creates3.  (S$K00RWW^^H5M5M(C':a"#&&(K;:"(m &$''%zz&1 & 7 3 &vvt< ' > #}'<"%k&8&8&A"B ZZ K(@A J'#&q#d)a-#8 fd++#[[]F#+)8v$,*:w"("3"3"5K#+.=F+$,/?G,3BB;OFm&AA.==hG  " "$$&&+$/OO** '4%4%O  , , . '&XXo00111_;:@B''&&&2sAJ I"EJ 0I(18J )I**J -!I0I,I0# J .I./"J J J  I% J *J ,I0.J 0J6I9 7 JJ cp# URSU3SS9IShvN n[R"U5$N7f)rXrYrZr[Nr]r^s rr5AsyncImportsClient.get s: YK&@OO$$X..P 646rac# UUS.R5VVs0sH up4UcM X4_M nnnURSUSS9IShvN n[R"U5$s snnfN 7f)reraNr*rZrfrgris rr=AsyncImportsClient.lists!eg  AD  mF5QQ"11(;; Rs A& AAA&A$!A&cr# URSU3USS9IShvN n[R"U5$N7f)rnrYrorpNr]rqs rrrAsyncImportsClient.update+s= YK&@vV]^^$$X.._s 757cp# URSU3SS9IShvN n[R"U5$N7f)rurYrvr[Nr]r^s rrwAsyncImportsClient.delete8s: YK&@RR$$X..Srryrzr{ch# [R"5R5nURU5IShvN nURS;aU$[R"5R5U- U:a[ SUSUS35e[R "U5IShvN MNrN7f)rNrrrr)asyncioget_event_looprr5rrrrs rr'AsyncImportsClient.wait_until_completedDs++-224 #xx 22J  $;;!!%%',,.;gE"WYK7PQXPYYa#bcc-- . . .2 /s"9B2B.A+B2'B0(B20B2rrrrrrrrs@rrrsf,!04 I2=I2- I2 - I2V /59QU<* / /LPfg//r r) __future__rrr/r9r;rrCrtypingrrrrpathlibrtypesr r r r r core.basercore.async_baserrrrr rrsW"  --*4_&%_&Db//b/r