Ji%I"ddlZddlZddlZddlZddlmZmZmZddlZddl m Z ddl m Z m Z mZmZddlmZmZmZmZmZmZmZddlmZddlmZddlmZmZerddlZ d e!d e"fd Z#Gd d e$Z%Gdde%Z&Gdde%Z'GddZ(y)N)AnyDict TYPE_CHECKING)AsyncLlamaCloud) AsyncRetryingretry_if_exceptionstop_after_attemptwait_exponential)FileUploadResponse JobStatusPresignedUrlResponseSpreadsheetJobSpreadsheetJobResultSpreadsheetParsingConfigSpreadsheetResultType)BASE_URL) FileClient)augment_async_errors FileInput exceptionreturncht|tjr|jjdvSy)z,Determine if an exception should be retried.)iiiiiF) isinstancehttpxHTTPStatusErrorresponse status_code)rs y/var/www/html/BankruptcyAI-uat/bankruptcy-ai/venv/lib/python3.12/site-packages/llama_cloud_services/beta/sheets/client.py_should_retry_exceptionr$s-)U223!!--1JJJ ceZdZdZy)SpreadsheetAPIErrorz)Base exception for spreadsheet API errorsN__name__ __module__ __qualname____doc__r rr"r"+s3r r"ceZdZdZy)SpreadsheetJobErrorz-Exception raised when a spreadsheet job failsNr#r(r rr*r*1s7r r*ceZdZdZy)SpreadsheetTimeoutErrorz%Exception raised when a job times outNr#r(r rr,r,7s/r r,ceZdZdZ d*dedzdedzdededededzd edzd ejdzd dfd Zd e eeffd Z d ejfdZ d e eeffdZ d+de dedzd efdZ d+dede ezdzd efdZ d,deded efdZded efdZej0fdededed efdZej0fdededed dfdZ d+de de ezdzd efdZ d+de dedzd efd Z d+dede ezdzd efd!Z d,deded efd"Zded efd#Z ej0fdededed efd$Z!ej0fdededed dfd%Z" d+de de ezdzd efd&Z#d-d'Z$d.d(Z%d-d)Z&y)/ LlamaSheetsz)Client for the LlamaCloud Spreadsheet APINapi_keybase_url max_timeout poll_interval max_retries project_idorganization_idasync_httpx_clientrc v|xstjjd|_|js t d|xs$tjjdt }t |jd|_||_ ||_ ||_ |xstjjd|_ |xstjjd|_ ||_tt!|j|j||j|j|_y ) aInitialize the LlamaSheets client. Args: api_key: API key for authentication. If not provided, will use LLAMA_CLOUD_API_KEY env var base_url: Base URL for the API max_timeout: Maximum time to wait for job completion in seconds poll_interval: Interval between status checks in seconds max_retries: Maximum number of retries for failed requests project_id: Project ID for file operations. If not provided, will use LLAMA_CLOUD_PROJECT_ID env var organization_id: Organization ID for file operations. If not provided, will use LLAMA_CLOUD_ORGANIZATION_ID env var async_httpx_client: Optional custom async httpx client LLAMA_CLOUD_API_KEYzfAn API key must be provided either as an argument or via the LLAMA_CLOUD_API_KEY environment variable.LLAMA_CLOUD_BASE_URL/LLAMA_CLOUD_PROJECT_IDLLAMA_CLOUD_ORGANIZATION_ID)tokenr0 httpx_clientr4r5N)osenvirongetr/ ValueErrorrstrrstripr0r1r2r3r4r5 _async_clientrr _files_client) selfr/r0r1r2r3r4r5r6s r__init__zLlamaSheets.__init__@s.G"**..1F"G ||x Orzz~~.DhOH ,,S1 &*&$P 7O(P. "**.. )3 8J' ll/   00 r cvi}|j|j|d<|j|j|d<|S)z-Get default query parameters for API requestsr4r5r?)rHparamss r_get_default_paramszLlamaSheets._get_default_paramstsA ?? &#'??F<    +(,(<(    %!&!2!2 d+!%"D !!!r c&d|jddS)z#Get common headers for API requestszBearer zapplication/json) Authorizationz Content-Type)r/rRs r _get_headerszLlamaSheets._get_headerss 't||n5.  r file_obj file_namect5tj|j|cdddS#1swYyxYw) Upload a file to the Files API. Args: file_obj: File to upload (path, bytes, or file-like object) file_name: Optional name for the uploaded filename Returns: FileUploadResponse with the uploaded file ID N)rasynciorun aupload_file)rHrWrXs r upload_filezLlamaSheets.upload_files6" # <;;t00:; < < < $9Afile_idconfigct5tj|j||cdddS#1swYyxYw)Create a new spreadsheet parsing job. Args: file_id: ID of the uploaded file config: Parsing configuration Returns: SpreadsheetJob with job details N)rr[r\ acreate_job)rHr`ras r create_jobzLlamaSheets.create_jobs<" # B;;t//@A B B B %:Ajob_idinclude_results_metadatact5tj|j||cdddS#1swYyxYw)aGet the status of a spreadsheet parsing job. Args: job_id: ID of the job include_results_metadata: Whether to include results metadata in the response Returns: SpreadsheetJobResult with job status and optionally results N)rr[r\aget_job)rHrgrhs rget_jobzLlamaSheets.get_jobs;" # P;;t}}V5MNO P P Prfct5tj|j|cdddS#1swYyxYw)CWait for a job to complete by polling. Args: job_id: ID of the job to wait for Returns: SpreadsheetJobResult when job is complete Raises: SpreadsheetTimeoutError: If job doesn't complete within max_timeout SpreadsheetJobError: If job fails N)rr[r\await_for_completion)rHrgs rwait_for_completionzLlamaSheets.wait_for_completions:" # B;;t88@A B B Br_ region_id result_typect5tj|j|||cdddS#1swYyxYw)+Download a region result (either region data or cell metadata). Args: job_id: ID of the job region_id: ID of the region result_type: Type of result to download (region or cell_metadata) Returns: Raw bytes of the parquet file N)rr[r\adownload_region_resultrHrgrprqs rdownload_region_resultz"LlamaSheets.download_region_results= " # ;;,,VY L    &;Az pd.DataFramect5tj|j|||cdddS#1swYyxYw)Download a region result as a pandas DataFrame. Args: job_id: ID of the job region_id: ID of the region result_type: Type of result to download (region or cell_metadata) Returns: pandas DataFrame N)rr[r\adownload_region_as_dataframerus rdownload_region_as_dataframez(LlamaSheets.download_region_as_dataframes= " # ;;2269kR   rwct5tj|j||cdddS#1swYyxYwaHigh-level method to parse a spreadsheet file. This method handles the entire workflow: 1. Upload the file 2. Create a parsing job 3. Wait for completion 4. Return results Args: file_obj: File to parse (path, bytes, or file-like object) config: Parsing configuration Returns: SpreadsheetJobResult with parsing results N)rr[r\aextract_regions)rHrWras rextract_regionszLlamaSheets.extract_regionss<(" # H;;t44XvFG H H HrfctK tt|jtdddt t d23d{}|5|j j||d{cdddcS777#1swYIxYw6 td #t$r}td||d}~wwxYww) rZ  multiplierminmaxTstopwaitretryreraiseN)external_file_idzFailed to upload file: Tenacity did not execute) rr r3r rrrGupload_content Exceptionr" RuntimeError)rHrWrXattemptes rr]zLlamaSheets.aupload_files L!.'(8(89%rB()@A "  g !%!3!3!B!B 9"C"  "566 L%(?s&CD! K LsuB8;BB A;B B !A?+A=,A?/ B:B8;B =A??B B B8 B5!B00B55B8cK| t}n%t|trtj|}t|ts t d||j ddd}|j } tt|jtddd ttd 23d{}|5|j}|j|jd |j!|| d{}|j#t%j|j'cdddcS77D#1swYxYw6 t-d#t($r}t+d ||d}~wwxYww)rcNz:config must be a dict or SpreadsheetParsingConfig instancejsonT)mode exclude_none)r`rarrrrz/api/v1/beta/sheets/jobs)headersrKrzFailed to create job: r)rrdictmodel_validaterC model_dumprLrr r3r rrrSpostr0rVraise_for_statusrrrr"r) rHr`rapayloadrKrclientrrs rrdzLlamaSheets.acreate_job-s >-/F  %-<qc&BC J KsyA4F7;E!2E6E7E:E!=AEE6E8 E!FEEE E! F! E>*E99E>>FcJK tt|jtdddt t d23d{}|5|j }d|i|j}|j|jd||j| d{}|jtj|jcdddcS77D#1swYxYw6 t#d #t$r}t!d ||d}~wwxYww) aGet the status of a spreadsheet parsing job. Args: job_id: ID of the job include_results_metadata: Whether to include results in the response Returns: SpreadsheetJobResult with job status and optionally results rrrTrNinclude_results/api/v1/beta/sheets/jobs/rrKzFailed to get job status: r)rr r3r rrrSrLrBr0rVrrrrrr"r)rHrgrhrrrKrrs rrjzLlamaSheets.aget_jobas> O!.'(8(89%rB()@A " P Pg  P!335F)+C.224.F&,ZZ==/)B6(K $ 1 1 3%&0& H --//>>x}}O P P  P  P P ",566 O%(B1#&FGQ N OsvD#;DC6C&C6D AC*#C($6C* D%D#&C6(C**C3 /D8 D# D  DD  D#cKtj}tj|z |jkr'|j|dd{}|jtj tj tjtjfvru|jtj tj fvr|Sd|j}|jr!|ddj|jz }t|tj|jd{tj|z |jkr'td|jd7*7Fw) rmT)rhNzJob failed with status: z Errors: z, zJob did not complete within z seconds)timer1rjstatusr SUCCESSPARTIAL_SUCCESSERRORFAILUREerrorsjoinr*r[sleepr2r,)rHrg start_time job_result error_msgs rrnz LlamaSheets.await_for_completionsFYY[ yy{Z'4+;+;;#}}Vd}SSJ  !!))!! % $$):):I>..svv666 :?7s1A)A##A)A%"A)A'A)%A)'A)cnK|jr#|jjd{yy7w)zClose all HTTP clients (async)N)rFacloserRs rrzLlamaSheets.acloses/   $$++- - -  -s *535cK|SwNr(rRs r __aenter__zLlamaSheets.__aenter__"s  sc@K|jd{y7wr)r)rH _exc_type_exc_val_exc_tbs r __aexit__zLlamaSheets.__aexit__%skkms )NNi,NNNr)T)rN)rr.)'r$r%r&r'rDintrrPrIrrLrSrVrr r^rrreboolrrkrorTABLEbytesrvr{rr]rdrjrnrtrzr~rrrr(r rr.r.=sP3##!%&*7;2 t2 *2  2  2  2 $J2 t2 "--42  2 hT#s(^"5#4#4" d38n <@ <! <.1Dj <  <$:>BB//$6B  B$=A P P59 P  PB#B2FB(.C-H-H +   2.C-H-H +   0:>HH//$6H  H4<@7!7.1Dj7 7<:>2727//$627  27j=A#7#759#7 #7J$ $ 9M$ T.C-H-H ;7;7;7+ ;7  ;7B.C-H-H :::+ :  :4:>77//$67  7:. r r.))r[rr@rtypingrrrrllama_cloud.clientrtenacityrrr r &llama_cloud_services.beta.sheets.typesr r r rrrrllama_cloud_services.constantsr!llama_cloud_services.files.clientrllama_cloud_services.utilsrrrr BaseExceptionrrrr"r*r,r.r(r rrs ++ .48 } )  -  1 iir