Ng% ddlZddlZddlZddlZddlZddlmZddlmZddl m Z m Z m Z m Z mZmZe rddlmZddlmZddlmZmZdZd d d d Zd ZdZejeZdddefdZeGddZ eGddZ!ddde e"e fde fdZ#ddde"ddde e"e fde!f dZ$deddefd Z%dS)!N) dataclass)StringIO) TYPE_CHECKINGAnyDictListLiteralOptional)WorkspaceClient) FunctionInfo)StatementParameterListItemStatementState__execution_args__30sdi) wait_timeout row_limit byte_limit UC_TOOL_CLIENT_EXECUTION_TIMEOUT120functionr returnc.ddlm}|j|jkS)NrColumnTypeName)databricks.sdk.service.catalogr data_type TABLE_TYPE)rrs k/var/www/html/ai-engine/env/lib/python3.11/site-packages/langchain_community/tools/databricks/_execution.py is_scalarr s%======  !: ::c0eZdZUeed<eded<dS)ParameterizedStatement statementr parametersN)__name__ __module__ __qualname__str__annotations__rr!rr#r# s-NNN1222222r!r#ceZdZUdZdZeeed<dZee ded<dZ eeed<dZ ee ed<defd Z dS) FunctionExecutionResultzy Result of executing a function. We always use a string to present the result value for AI model to consume. Nerror)SCALARCSVformatvalue truncatedrcpd|jD}tj|S)Nci|] \}}||| SNr+).0kvs r z3FunctionExecutionResult.to_json..3sJJJ!QAM1MMMr!)__dict__itemsjsondumps)selfdatas rto_jsonzFunctionExecutionResult.to_json2s3JJ4=#6#6#8#8JJJz$r!)r&r'r(__doc__r.r r)r*r1r r2r3boolrAr+r!rr-r-&s  E8C=15FHW_- .555E8C= $Ix~$$$       r!r- json_paramscvddlm}ddlm}g}g}t |r|d|jdn|d|jd|j |jj|r Jdng}d}|jjD]H}|j |vr"|j d }td |j d d } |r | |j d z } ||j } |j |j |j|jfvrPt!j| } | d|j d|jdz } |||j | n||j |jkr4| d|j dz } |||j | n8| d|j z } |||j | |j|| J|d||dd |} t+| |S)Nrr)r zSELECT (zSELECT * FROM z8Function has no parameters but parameters were provided.FTz Parameter z is required but not provided.z => z from_json(:z, 'z'))namer2z unbase64(:):)rHr2type,)r$r%)rrdatabricks.sdk.service.sqlr r append full_name input_paramsr%rHparameter_default ValueError type_nameARRAYMAPSTRUCTr=r> type_textBINARYjoinr#) rrDrr parts output_paramsargsuse_named_argsp arg_clause json_valuejson_value_strr$s rget_execute_function_sql_stmtrb7s>=====EEEEEE EM= 4x14445555 ;h&8;;;<<<$(=(H(P F F E F F F F&1& (& (Av[((&2%)NN$KQVKKK !2QV///1J(0 ;"("&")# &*Z %;%;N"J"J"J1;"J"J"JJJ!((22nUUU[N$999"8qv"8"8"88J!((22jQQQ,af,,.J!((22!"z   J'''' SXXd^^$$$ LLI !I- P P PPr!wsr warehouse_idr%c  ddl}n"#t$r}td|d}~wwxYwddlm}|jrO|jjrCt d|jjDr tdtdtdit}tj |j j j}t d |Dst} |ti} | D]$\} } | |vr| || <| | %| r(td | d |dt)||} |j j d"| j|| jd |}|jrDt/|jjr*|jr"|j}d}d}t5t6jt<t>}||krtAd |z||z }tB"d|d|dtGj$||j %|}|jt/|jjsn||z }|dz }||k|jr=t/|jjr$tMd|dt<dt>dS|j Jd||jj|j'kr:|jj(}| Jd|tM|j)d|j*S|j+}|J|j,}|j-}| Jd|j.}t_|r]d}|rGta|dkr4ta|ddkrtc|dd}tMd||S|j2}||j3 Jdd|j3D}|g}|j45||}tm}|7|d tMd!|8|S)#zL Execute a function with the given arguments and return the result. rNzTCould not import pandas python package. Please install it with `pip install pandas`.rc36K|]}|jtkVdSr6)rHEXECUTE_FUNCTION_ARG_NAMEr7r^s r z#execute_function..s>   F/ /      r!zRParameter name conflicts with the reserved argument name for executing functions: z. Please rename the parameter .c3@K|]}|j|j|jfvVdSr6)kindVAR_POSITIONAL VAR_KEYWORDris rrjz#execute_function..sG  1#Q]33r!z,Invalid parameters for executing functions: z. Allowed parameters are: )r$rdr%z Retrying z. time to get statement execution status after z seconds.z+Statement execution is still pending after z[ seconds. Please increase the wait_timeout argument for executing the function or increase z? environment variable for increasing retrying time, default is )r.zStatement execution failed: z>Statement execution failed but no error message was provided: z: z9Statement execution succeeded but no result was provided.r/)r1r2r3z9Statement execution succeeded but no schema was provided.cg|] }|j Sr+)rH)r7cs r z$execute_function..s222a16222r!)columnsF)indexr0r+)9pandas ImportErrorrMrrPr%anyrRrhDEFAULT_EXECUTE_FUNCTION_ARGSinspect signaturestatement_executionexecute_statementvaluessetpopr<addkeysrbr$status job_pendingstate statement_idintosenvirongetr(DEFAULT_UC_TOOL_CLIENT_EXECUTION_TIMEOUTmin_loggerdebugtimesleep get_statementr- SUCCEEDEDr. error_codemessagemanifestr3result data_arrayr lenr)schemaru DataFrame from_recordsrto_csvgetvalue)rcrdrr%pderexecute_statement_argsallowed_execute_statement_argsinvalid_paramspassed_execute_statement_argsr8r9parametrized_statementresponser wait_time retry_cntclient_execution_timeoutwaitr.rr3rrr2rrupdf csv_buffers rexecute_functionrys  ;    :99999    ! ,     *5        H3 H H+D H H H   ? =>%,%6 0&&# /6688  (27PRT(U(U%17799 & &DAq222,-&q))""1%%%%  T~TT+I+N+N+P+PTTT  ;8ZPP7r%7(2!)4 ! H ;x'<==(BW,   #& JNN08  $ $  222q)|%= %IJJD MM0I00 $000    Jt   -;;LIIH&k(/:O.P.P&  I NI222 ? {8?+@AA *GIGG,LGG< GGG  ? & &(Qx(Q(Q & & & 888%    VH V V   &0@-S-SEM-S-STTTT H    "I _FB "J   *#j//A--#jm2D2Dq2H2H 1 a())E&5I      6>#=#= F$>#=#=226>222  Jl'' G'DDZZ  :U +++& 3 3 5 5    s &!&rrc.ddlm}||j|jfvS)Nrrf)rMrPENDINGRUNNING)rrs rrrs*999999 ^+^-CD DDr!)&r{r=loggingrr dataclassesriortypingrrrrr r databricks.sdkr rr rMr rrhrzrr getLoggerr&rrCr r#r-r)rbrrr+r!rrs\  !!!!!!DDDDDDDDDDDDDDDDV......;;;;;;UUUUUUUU0!! $F +0( ' H % %;;4;;;;  3333333 3             ?Q?Q+/S>?Q?Q?Q?Q?QD    S#X       DEx 01EdEEEEEEr!