+ i;caR;t@0tRt^RIt^RIt^RIt^RIt^RIt^RIt^RIHtH t H t H t H t H t Ht^RIt^RIt^RIt^RIHt^RIHt^RIHt^RIHt^RIHt^RIHt]P6R<8d^R IHtM ]P:t]P<'d^R IH t!^R I"H#t$M]t!]^k]t$]^k^R IH t!^R I"H#t$^ t&]PN!R 4t(R Rlt)RRlt*RRlt+R=RRllt,R=RRllt-R>RRllt.RRlt/RRlt0RRlt1RR lt2R!R"lt3R#R$lt4R%R&lt5R'R(lt6R)R*lt7R=R+R,llt8R=R-R.llt9R/R0lt:R=R1R2llt;R=R3R4lltR?R9R:llt?R# ]%dRt!Rt$Li;i)@zNExtra utils depending on types that are shared between sync and async modules.N)AnyCallableDictOptionalUnionget_args get_origin)_common) _mcp_utils) _transformers)errors)types)McpToGenAiToolAdapter) UnionType) ClientSession)Toolzgoogle_genai.modelscXV^8dQhR\PR\P/#configreturn)r GenerateContentConfigOrDictGenerateContentConfig)formats"l/Users/igloo/.openclaw/workspace/scratch/fb_ad_env/lib/python3.14/site-packages/google/genai/_extra_utils.py __annotate__r<s(  - -   c^\V\4'd\P!R/VB#V#)N) isinstancedictr r)rs&r%_create_generate_content_config_modelr!<s*  & & 0 00 Mrc|V^8dQhR\\\P3,R\\,/#rsrcrrstrr BatchJobSourceOrDictr)rs"rrrE0   sE... /  c] rc\V\4'dVPR4'dV#\V\4'd9VP R4'd"VR,'dVR,^,#R#\V\ P 4'd:VP'd(VP'dVP^,#R#R#)z9Extracts the first GCS URI from the source, if available.zgs://gcs_uriN)rr& startswithr getr BatchJobSourcer*r$s&r _get_gcs_urir/EsScnnW55 J#t!3!3 #I3y>! 8D8#u++,, [[[3;;q>2d2 rc|V^8dQhR\\\P3,R\\,/#r#r%)rs"rrrRr(rcL\V\4'dVPR4'dV#\V\4'd!VP R4'd VR,#\V\ P 4'dVP'd VP#R#)z8Extracts the BigQuery URI from the source, if available.zbq:// bigquery_uriN)rr&r+r r,r r-r2r.s&r_get_bigquery_urir3RswScnnW55 J#t!8!8 ~ #u++,,1A1A1A    rcV^8dQhR\\\P3,R\\P ,R\P /#)rr$rr)rr&r r-rCreateBatchJobConfig)rs"rrr_sG sE((( ) U// 0 rcVf\P!4pRpVP'g \P!4pRV 2VnVP 'gx\ V4p\V4pV'd'VPR4'dVRR R2VnV#V'd,T;'g\P!4pV RV 2VnV#)zBFormats the destination uri based on the source uri for Vertex AI.Ngenai_batch_job_z.jsonlz/dest_dest_i) r r5 display_namer timestamped_unique_namedestr/r3endswith)r$r unique_namegcs_source_uribigquery_source_uris&& rformat_destinationr@_s  ^  ' ' )F+    113K,[M:F !#&N+C0.11(;;%cr*+51fk - DD7#B#B#Dk*+6+?fk -rcpV^8dQhR\\P,R\\,/#r)rr rlistint)rs"rrrys+$$ U66 7$ #Y$rc|V'g.#\V4p.pV'dVP'gV#\VP4Fowr4\V\P 4'gK'VP 'dVPV4VP'gK^VPV4Kq V#)a@Checks if the config contains any AFC incompatible tools. A `types.Tool` object that contains `function_declarations` is considered a non-AFC tool for this execution path. Args: config: The GenerateContentConfig to check for incompatible tools. Returns: A list of indexes of the incompatible tools in the config. ) r!tools enumeraterr rfunction_declarationsappend mcp_servers)r config_modelincompatible_tools_indexesindextools& r"find_afc_incompatible_tool_indexesrNys  I6v>,*, \/// %%|112ke dEJJ ' ' !!! ''.  ''. 3 $#rc V^8dQhR\\P,R\\\\ 3,,R\ R\\\\R\3,\ 3,3,/#)rrmcp_to_genai_tool_adaptersis_caller_method_asyncr.) rr rr r&rboolrrr)rs"rrrsl!! U66 7! ( S' '(!! ! !  #uXc3h')>>? ?@ !rcV/pV'gV#\V4pVP'dVPFyp\V4'gK\P!V4'd:V'g2\ P !RVP RVP R24hWSVP&K{ V'doV'g\ P !R4hVP4F+wrgVPV4'gK\RV R24h VPV4V#)z'Returns a function map from the config.z Function zh is a coroutine function, which is not supported for automatic function calling. Please manually invoke z to get the function response.z3MCP tools are not supported in synchronous methods.Tool $ is already defined for the request.) r!rEcallableinspectiscoroutinefunctionr UnsupportedFunctionError__name__itemsr, ValueErrorupdate)rrPrQ function_maprJrM tool_name_s&&& rget_function_maprasOQ,  6v>,"" $  & &t , ,5K//$--)'EG  '+T]]## !  + + ? 388:   ) $ $I;B C  ; 23 rcXV^8dQhR\PR\P/#rargsr)r StringDict)rs"rrrs(    rcjVP4UUu/uFwrV\V4bK upp#uuppi)z:Converts float values in dict with no decimal to integers.)r[,convert_number_values_for_function_call_argsrdkeyvalues& r1convert_number_values_for_dict_function_call_argsrks<   $*# 7 >>$  s/cV^8dQhR\\\\3,\\,\3,R\\\\3,\\,\3,/#rc)rr r&objectrB)rs"rrrsN S&[!4<7 8 4V d6lF 23rct\V\4'd"VP4'd \V4#\V\4'd/VP 4UUu/uFwrV\ V4bK upp#\V\4'dVUu.uFp\ V4NK up#V#uuppiuupi)z2Converts float values with no decimal to integers.)rfloat is_integerrCr r[rgrBrhs& rrgrgse!2!2 t9d**, &JC 9% @@& dIM IM4U;  +   s !B/B5c0V^8dQhR\R\/#)r annotationr)rrR)rs"rrrs  S T rc\P!V4;'d\V\P4# \ dR#i;i)F)rWisclass issubclasspydantic BaseModel TypeError)rrs&ris_annotation_pydantic_modelrysH ??: &  :H&&,  s:: A A c TV^8dQhR\R\R\R\R\/#)rrjrr param_name func_namer)rr&)rs"rrrs4;; ;;-0;=@;;rc \V\4'd\V4'd V!R/VB#\V\4'dC\V4\8Xd/\V4^,pVUu.uFp\WeW#4NK up#\V\4'dQ\V4\8Xd=\V4wrxVP4U U u/uFwrV \WW#4bK up p #\V4\\39d\V4Fpp \V 4'd\V 4\Jg=\W 4'g,\V\4'gKP\V 4'gKc\W W#4u# \ P !RV RV RV RV R2 4h\V\4'd V\JdV#\W4'g$\ P !RV RV RV RV R2 4hV# \Pd+p\ P !RT RT RT RT RT 2 4hRp?ii;iuupiuup p i \PdEKUi;i) zFailed to parse parameter z for function z> from function call part because function call argument value z- is not compatible with parameter annotation z, due to error Nz- cannot be converted to parameter annotation .r)rr ryrvValidationErrorr UnknownFunctionCallArgumentErrorrBrrconvert_if_exist_pydantic_modelr[rrrCro) rjrrr{r|e item_typeitemr` value_typekvargs &&&& rrrs}t!=j!I!I  %  tJ!74!?$Q'I D (O tJ!74!?Z(MAKKM !DA *1* PP!   y11 # C==Z_4  # #%%*Fs*K*K 0*  $  1 1 $ZL1 ; >]?  ""#56)5*   ,"CF+- ,s#E.. F9 F  Fc V^8dQhR\PR\\\\ R\ 3,\3,3,R\\P,/#rr)rs"rrrssS..++.sE(38"46K"KLLM. %**.rch".pVPEe\VP^,P\P4'EdVP^,PP EeVP^,PP EF_pVP 'gKVP PpVfK4VP PfKNW,p\VP P4p\V\4'dKVP\P!WFR74GRjxL pVP'dRV/pM]RV/pMX\P!V4'dR\!We4GRjxL /pM&R\"P$!\&We4GRjxL /p\P,P/WHR7p VP1V 4EKb V#LLfLB \(dp R\+T 4/pRp ? L[Rp ? ii;i5i)rN)rrdrrr)rrrr rrrrrdrkr call_tool FunctionCallisErrorrWrXrasyncio to_threadrrr&rrrH) rr^rrr|rrdmcp_tool_responserrrs && r!get_function_response_parts_asyncrss % X((+33U]] C C   a ( ( . . :##A&..44    $$))i  4#5#5#:#:#F&@    # #  , 3 4 4&*nn"" ='! !(((&(9:m'):;m**400 DT PPM  1 12D!M#ZZ>>?  ""#56E5F /!Q ,"CF+- ,sCH2H2/'H2?H HH -H 1H22H 6H27H H "H #H (H2)H H  H 9H2H  H  H  H/ H*%H2*H//H2cZV^8dQhR\\P,R\/#rrr rrR)rs"rrrs'4949 U66 749 49rcV'gR#\V4pV'dVP'dmVPPeT\VPP4^8:d0\P RVPP R24R#VP'dVPP fR#VPP 'dVPPemRVPP9dR\VPP4^8d.\P RVPP R24VPP #)z6Returns whether automatic function calling is enabled.Fz6max_remote_calls in automatic_function_calling_config zu is less than or equal to 0. Disabling automatic function calling. Please set max_remote_calls to a positive integer.Tmaximum_remote_callsz`automatic_function_calling.disable` is set to `True`. And `automatic_function_calling.maximum_remote_calls` is a positive number a9. Disabling automatic function calling. If you want to enable automatic function calling, please set `automatic_function_calling.disable` to `False` or leave it unset, and set `automatic_function_calling.maximum_remote_calls` to a positive integer or leave `automatic_function_calling.maximum_remote_calls` unset.)r!automatic_function_callingrrCloggerwarningdisablemodel_fields_setrrJs& rshould_disable_afcrsO  6v>,  1 1 1  1 1 F F   l55JJ Kq P NN  3 3 H H IJ> >   1 1 1  0 0 8 8 @ --555  1 1 F F   !  0 0 A A B l55JJ Ka O NN   3 3 H H IJD D   0 0 8 88rcZV^8dQhR\\P,R\/#r)rr rrC)rs"rrrs+KK U66 7KKrc V'g\#\V4'd \R4h\V4pVP'dVPP f\#\ VPP 4#)zUautomatic function calling is not enabled, but SDK is trying to get max remote calls.)_DEFAULT_MAX_REMOTE_CALLS_AFCrr\r!rrrCrs& rget_max_remote_calls_afcrst  ((J   7v>,  1 1 1  0 0 E E M (( \ 4 4 I I JJrcRV^8dQhR\\P,RR/#)rrrN)rr r)rs"rrrs&HU=X=X4Y rc4V'd/VP'dVPP'gR#VPpV'd VPMRpVPPPpV'dV'g \ R4hR#R#)z9Raises an error if the config is not compatible with AFC.NFavRunning in streaming mode with stream_function_call_arguments enabled, this feature is not compatible with automatic function calling (AFC). Please set config.automatic_function_calling.disable to True to disable AFC or leave config.tool_config. function_calling_config.stream_function_call_arguments to be empty or set to False to disable streaming function call arguments.) tool_configfunction_calling_configrrstream_function_call_argumentsr\)r afc_configdisable_afc_configstream_function_calls& r'raise_error_for_afc_incompatible_configrs         7 7 7 00*-7z))U 00OO"4  I #5rcZV^8dQhR\\P,R\/#rr)rs"rrrs+II U66 7I IrcV'gR#\V4pVP'gR#VPP'*#)T)r!rignore_call_historyrs& rshould_append_afc_historyrs8  6v>,  0 0 0   4 4 H H HHrcV^8dQhR\\P,R\\P,/#r)rr rr)rs"rrrs2 U66 7 e))*rcV'gR#\V4pVPRR/R7pVPVnVP'd\P!VP4'd~VP f\ P!/R7VnVP Pf/VP n\P!VP P4V#)zVReturns a parsed config with an appended MCP header if MCP tools or sessions are used.NrEr])headers) r! model_copyrEr has_mcp_tool_usage http_optionsr HttpOptionsrset_mcp_usage_header)rrJconfig_model_copys& rparse_config_for_mcp_usagers  6v>,#--gt_-E(..J99,:L:LMM%%-','8'8'D$%%--5/1$$,##$5$B$B$J$JK rcV^8dQhR\\P,R\\\P,\ \ \3,3,/#r)rr rtuplerr r&r)rs"rrr(sM)8)8 U66 7)8  U ( ()# #$&)8rc"/p\V4pV'gRV3#VPRR/R7pVP'Ed5.VnVPEFp\e\ V\4'd\ YDP 4GRjxL 4pVPPVP4VPFpVP'gKVPF_pVP'gKVPVP4'd\RVP R24hVWP&Ka K EKVPPV4EK W13#L5i)zReturns a parsed config with MCP sessions converted to GenAI tools. Also returns a map of MCP tools to GenAI tool adapters to be used for AFC. NrErrTrU) rrrEMcpClientSessionrr list_toolsextendrGrr,r\rH)rrP parsed_configparsed_config_copyrMmcp_to_genai_tool_adapter genai_toolfunction_declarations& rparse_config_for_mcp_sessionsr(s`BD,V4-  + ++%///G!##  %*T;K*L*L$9 ))% !   ''(A(G(GH399J  - - -(2(H(H$%***-112F2K2KLL"27789&& .++D+DE)I:   ''-)$,  77'*s-AE<A E<E: A E<!E< E<%AE<cV^8dQhR\\P\P3,R\PR\\P\P3,/#)rcontentschunkr)rr ContentListUnionContentListUnionDictr)rs"rrrTsX  E**E,F,FFG   ( (  5 ! !5#=#= => rcVemVPe_VP^,Pp\P!V4p\ V\ 4'dVeVP V4V#)zFAppends the contents of the chunk to the contents list and returns it.)rrt t_contentsrrBrH)rr chunk_contents&& rappend_chunk_contentsrTs\  5++7$$Q'//M||H%H(D!!m&?oom$ /rc 2V^8dQhR\\\P\,\P 3,R\ \P,R\ \,R\\P\\3,/#)rfileuser_http_optionsuser_mime_typer) rr&osPathLikeioIOBaserr HttpOptionsOrDictrrrC)rs"rrraswF-F- R[[%ryy0 1F- 7 78F-SMF-    F-rc RpTp\V\P4'dVf \R4h\ VR4'dRVP 9d \R4hVP 4pVP^\P4VP 4V, pVPV\P4M\P!V4pV'd&\PPV4'g\V R24h\PPV4pVf\ P"!V4wrGVf \R4hV'dJ\V\$4'd\&P(!R/VBpTpRVnR R R R R RRV RV /VnM$\&P(!RR R R R R RRV RV /R7p\V\.\P034'dBVP,f/Vn\PP3V4VP,R&WV3#)a%Prepares the HTTP options, file bytes size and mime type for a resumable upload. This function inspects a file (from a path or an in-memory object) to determine its size and MIME type. It then constructs the necessary HTTP headers and options required to initiate a resumable upload session. NzfUnknown mime type: Could not determine the mimetype for your file please set the `mime_type` argumentmodebz'The file must be opened in binary mode.z is not a valid file path.ziUnknown mime type: Could not determine the mimetype for your file please set the `mime_type` argumentz Content-Typezapplication/jsonzX-Goog-Upload-Protocol resumablezX-Goog-Upload-Commandstartz#X-Goog-Upload-Header-Content-Lengthz!X-Goog-Upload-Header-Content-Type) api_versionrzX-Goog-Upload-File-Namer)rrr r\hasattrr tellseekrSEEK_ENDSEEK_SETfspathpathisfileFileNotFoundErrorgetsize mimetypes guess_typer r rrrr&rbasename) rrr size_bytes mime_typeoffsetfs_pathr`rs &&& rprepare_resumable_uploadr#as*)bii    8 tV DII BCC YY[FIIav%JIIfbkk"iioG "''..11 &@A BB)J))'2li  ;  #T**++@.?@$L!L* +-*+ { L$$ . $k #W 1j\ /I;   LsBKK())#! 68gg6F6Ft6LL23 9 ,,rcV^8dQh/^\9d\P;R&^\9d\P;R&#)rrMcpTool)__conditional_annotations__typingType)rs"rrrs6TT<&%FKK%=U>6;;?Ur) r)NNF)NN)Ar&__doc__rrWrloggingsysr'rrrrrrrrrrvrr r r rr r _adaptersr version_infor_UnionGenericAlias TYPE_CHECKINGmcprr mcp.typesrr% ImportErrorr getLoggerrr!r/r3r@rNrarkrgryrrrrrrrrrrrrrr#r)r&s@rr6sG U  MMM  ,w'') 3'"%%'5) !#   0 1  4$@!H$ ;|"   F.b49nK(2I*)8X F-F-] Gs3 E11 E?>E?