o pkjC@sdZddlmZmZddlmZmZmZmZddl m Z m Z m Z ddlm Z mZmZmZddlmZmZddlmZmZddlmZd d lZd d lmZmZmZmZm Z Gd d d eZ!GdddZ"GdddZ#GdddeZ$GdddZ%GdddZ&d S)zACode generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.) AsyncBaseSDKBaseSDK)errorsmodelstypesutils)AfterParseErrorContext HookContextResponseContext)OptionalNullableUNSET interactionstriggers)triggercreateparams triggerupdate)get_security_from_envresponse_helpers)unmarshal_json_responseN)AnyMappingOptionalUnioncastc@>eZdZeddZeddZdddddddddeedeed eed eed ee eefd ee ee fd ee e e jfdejfddZdddddddddd de ejejfdededeedeedeedeedeed ee eefd ee ee fdee ee fd ee e e jfdejfddZddddddedeed ee eefd ee ee fd ee e e jfdejf ddZddddddedeed ee eefd ee ee fd ee e e jfdejf d d!Zdddddddd"dedeedeed#eejd ee eefd ee ee fdee ee fd ee e e jfdejfd$d%Zddddddd&d'edeed eed eed ee eefd ee ee fd ee e e jfdejfd(d)Zdddddd'edeed ee eefd ee ee fd ee e e jfdej f d*d+Z!dS),TriggerscCt|SN)TriggersWithRawResponseselfr!Y/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/google/genai/_gaos/triggers.pywith_raw_response"zTriggers.with_raw_responsecCrr)TriggersWithStreamingResponserr!r!r"with_streaming_response&r$z Triggers.with_streaming_responseN api_versionfilter_ page_size page_token extra_headers extra_querytimeoutr(r)r*r+r,r-r.returnc Csd}d} t} d} |} ||} | dur|jj} | dur| }n||| }tj||||d}t| \}} |j d3iddddd|d| d |d d d d dd ddddd| d|dtj |jj j dd|jj ddd| }| tkr|jjtur|jj} ntjdtddddd dd } d}t| tjr| gd!f}d"d#}t|j|pd$d%dt|jj tjddt|d&d'd(}|j||d)d*|d+k|d,}|d-kr$td.d/g|jr|z||Wn!ty}zt|jjd0t|||WYd}~nd}~ww|d+kr tj ntj!}t"t#|||d1|t||jj$d0d2Sz||WStyK}zt|jjd0t|||WYd}~dSd}~ww)4[Lists triggers for a project. :param api_version: Which version of the API to use. :param filter_: Optional. Filter expression (e.g., by state). :param page_size: Optional. The maximum number of triggers to return per page. :param page_token: Optional. A page token from a previous ListTriggers call. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param timeout: Override the default request timeout configuration for this method in seconds Nr(r)r*r+methodGETpath/{api_version}/triggersbase_url url_variablesrequestrequest_body_requiredFrequest_has_path_paramsTrequest_has_query_paramsuser_agent_header user-agentaccept_header_valueapplication/json http_headersextra_query_params_globalsr(securityallow_empty_value timeout_msattempt-count-backoff@0u max_retries4084094295XXcSvt|ddrttj|ddSt|ddr"t|}td||t|ddr5t|}td||td | N200r?F)validate4XX*zAPI error occurredrSzUnexpected response received)rmatch_responserrListTriggersResponsestream_to_textrGenAiDefaultErrorhttp_res http_res_textr!r!r"_speakeasy_parse_response{   z0Triggers.list.._speakeasy_parse_response ListTriggerssyncmode executionconfigr6 operation_id oauth2_scopessecurity_sourcetags extensionsresponsecStddg|SNrXrSrmatch_status_codescr!r!r"zTriggers.list.. streaminghook_ctxr8is_error_status_codestream retry_configparsedrXrS_hooksbufferedrawparserrg client_refr{hooksr!)%r _coerce_timeout_mssdk_configurationrF_get_urlrListTriggersRequestrconsume_response_mode_build_requestListTriggersGlobalsglobalsr(rDr~r RetryConfigBackoffStrategy isinstancer rrSecurityr do_requestrt status_coderead Exceptionraise_parse_error__dict__rStreamedAPIResponse APIResponserrgetr r(r)r*r+r,r-r.r6r7retries server_urlr@rFr8_speakeasy_response_modereqr~ra_speakeasy_hook_ctxr_ parse_exc__speakeasy_response_clsr!r!r"list*                      z Triggers.list r( display_nameenvironment_idexecution_timeout_secondsmax_consecutive_failuresr,r- extra_bodyr. interactionschedule time_zonerrrrrc  sd} d}t}d}| }|| }|dur|jj}|dur|} n|| |} tj|tj|||t |tj |||ddt |\}}|jd5iddddd| d |d d d d d dd ddddd|d| dtj|jjjdd|jjdfddddd|}|tkr|jjtur|jj}nt jdt ddd d!d d"d#}d}t|t jr|gd$f}d%d&}t|j| pd'd(dt|jjtjddt|d)d*d+}|j||d,d|d-k|d.}|d/kr9t d0d1g|jr|z||Wn!t y}zt !|jj"d2t#|||WYd}~nd}~ww|d-kr"t j$nt j%}t&t'|||d3|t#||jj"(d2d4Sz||WSt y`}zt !|jj"d2t#|||WYd}~dSd}~ww)6Creates a new trigger that will invoke the specified agent on the given cron schedule. :param interaction: Required. The interaction request template to be executed. :param schedule: Required. The cron schedule on which the trigger should run. Standard cron format. :param time_zone: Required. Time zone in which the schedule should be interpreted. :param api_version: Which version of the API to use. :param display_name: Optional. The display name of the trigger. :param environment_id: Optional. The environment ID for the trigger execution. :param execution_timeout_seconds: Optional. The execution timeout for the triggered interaction. :param max_consecutive_failures: Optional. The maximum number of consecutive failures allowed before the trigger is automatically paused (status becomes ERROR). :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param extra_body: Additional JSON object fields to merge into request bodies. :param timeout: Override the default request timeout configuration for this method in seconds Nrrrrrrrr(bodyr2POSTr4r5r6r7r8r9Tr:r;r<r=r>r?r@rArBrCrDget_serialized_bodyctjjdddtjdSNFjson)rrserialize_request_bodyrrTriggerCreateParamsr!rr8r!r"rwz!Triggers.create..rErFrGrHrIrJrKrLrMrOcSrTrUrrZrrTriggerr\rr]r^r!r!r"ra2rbz2Triggers.create.._speakeasy_parse_responserc CreateTriggerrerfricSrqrrrsrur!r!r"rwSrxryrzrrXrSrrrr!))r rrrFrrCreateTriggerRequestrrrget_pydantic_model InteractionrrrCreateTriggerGlobalsrr(rDr~rrrr rrrr rrtrrrrrrrrrrrr rrrr(rrrrr,r-rr.r6r7rrr@rFrrr~rarr_rrr!rr"creates"                        zTriggers.creater(r,r-r.idc Cd}d}t}d} |} ||} | dur|jj} | dur| }n|||}tj||d} t| \} } |j d3iddddd|d|d | d d d d dd ddddd| d|dtj |jj j dd|jj ddd| }|tkr|jjtur|jj}ntjdtddddd dd }d}t|tjr|gd!f}d"d#}t|j|pd$d%dt|jj tjddt| d&d'd(}|j||d)d*| d+k|d,}| d-kr"td.d/g|jr|z||Wn!ty}zt|jjd0t|||WYd}~nd}~ww| d+kr tj ntj!}t"t#|||d1|t||jj$d0d2Sz||WStyI}zt|jjd0t|||WYd}~dSd}~ww)4Deletes a trigger. :param id: Resource name of the trigger. :param api_version: Which version of the API to use. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param timeout: Override the default request timeout configuration for this method in seconds Nr(rr2DELETEr4/{api_version}/triggers/{id}r6r7r8r9Fr:Tr;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrOcSrTrU)rrZrr Emptyr\rr]r^r!r!r"rarbz2Triggers.delete.._speakeasy_parse_responserc DeleteTriggerrerfricSrqrrrsrur!r!r"rwrxz!Triggers.delete..ryrzrrXrSrrrr!)%r rrrFrrDeleteTriggerRequestrrrDeleteTriggerGlobalsrr(rDr~rrrrr rrrr rrtrrrrrrrrrrrr rr(r,r-r.r6r7rrr@rFr8rrr~rarr_rrr!r!r"delete}                      zTriggers.deletec Cr)4Gets details of a single trigger. :param id: Resource name of the trigger. :param api_version: Which version of the API to use. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param timeout: Override the default request timeout configuration for this method in seconds Nrr2r3r4rr6r7r8r9Fr:Tr;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrOcSrTrUrr^r!r!r"ra^rbz/Triggers.get.._speakeasy_parse_responserc GetTriggerrerfricSrqrrrsrur!r!r"rwrxzTriggers.get..ryrzrrXrSrrrr!)%r rrrFrrGetTriggerRequestrrrGetTriggerGlobalsrr(rDr~rrrrr rrrr rrtrrrrrrrrrrrrr!r!r"rrz Triggers.getr(rstatusr,r-rr.rc sd} d} t} d} |} ||}|dur|jj}| dur| } n|| | } tj||tj||ddt | \}} |j d5iddddd| d | d d d d d dd ddddd| d|dtj |jj jdd|jjdfddddd|}| tkr|jjtur|jj} ntjdtddd d!d d"d#} d}t| tjr| gd$f}d%d&}t|j| pd'd(dt|jjtjddt|d)d*d+}|j||d,d|d-k|d.}|d/kr0td0d1g|jr|z||Wn!ty}zt |jj d2t!|||WYd}~nd}~ww|d-krt j"nt j#}t$t%|||d3|t!||jj &d2d4Sz||WStyW}zt |jj d2t!|||WYd}~dSd}~ww)6jUpdates a trigger. :param id: Resource name of the trigger. :param api_version: Which version of the API to use. :param display_name: Optional. The display name of the trigger. :param status: Optional. The status of the trigger. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param extra_body: Additional JSON object fields to merge into request bodies. :param timeout: Override the default request timeout configuration for this method in seconds Nrrr(rrr2PATCHr4rr6r7r8r9Tr:r;r<r=r>r?r@rArBrCrDrcrrrrrr TriggerUpdater!rr!r"rwrz!Triggers.update..rErFrGrHrIrJrKrLrMrOcSrTrUrr^r!r!r"rarbz2Triggers.update.._speakeasy_parse_responserc UpdateTriggerrerfricSrqrrrsrur!r!r"rw'rxryrzrrXrSrrrr!)'r rrrFrrUpdateTriggerRequestrrrrrUpdateTriggerGlobalsrr(rDr~rrrrr rrrr rrtrrrrrrrrrrrr rr(rrr,r-rr.r6r7rrr@rFrrr~rarr_rrr!rr"updates                       zTriggers.updater(r*r+r,r-r. trigger_idc Csd}d} t} d} |} ||} | dur|jj} | dur| }n||| }tj||||d}t| \}} |j d3iddddd|d| d |d d d d dd ddddd| d|dtj |jj j dd|jj ddd| }| tkr|jjtur|jj} ntjdtddddd dd } d}t| tjr| gd!f}d"d#}t|j|pd$d%dt|jj tjddt|d&d'd(}|j||d)d*|d+k|d,}|d-kr$td.d/g|jr|z||Wn!ty}zt|jjd0t|||WYd}~nd}~ww|d+kr tj ntj!}t"t#|||d1|t||jj$d0d2Sz||WStyK}zt|jjd0t|||WYd}~dSd}~ww)4[Lists executions for a trigger. :param trigger_id: Resource name of the trigger. :param api_version: Which version of the API to use. :param page_size: Optional. The maximum number of executions to return per page. :param page_token: Optional. A page token from a previous ListTriggerExecutions call. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param timeout: Override the default request timeout configuration for this method in seconds Nr(rr*r+r2r3r4//{api_version}/triggers/{trigger_id}/executionsr6r7r8r9Fr:Tr;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrOcSrTrU)rrZrrListTriggerExecutionsResponser\rr]r^r!r!r"rarbz;Triggers.list_executions.._speakeasy_parse_responsercListTriggerExecutionsrerfricSrqrrrsrur!r!r"rwrxz*Triggers.list_executions..ryrzrrXrSrrrr!)%r rrrFrrListTriggerExecutionsRequestrrrListTriggerExecutionsGlobalsrr(rDr~rrrrr rrrr rrtrrrrrrrrrrrr rr(r*r+r,r-r.r6r7rrr@rFr8rrr~rarr_rrr!r!r"list_executionsQrzTriggers.list_executionsc Cr)4Runs a trigger immediately. :param trigger_id: Resource name of the trigger. :param api_version: Which version of the API to use. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param timeout: Override the default request timeout configuration for this method in seconds Nr(rr2rr4rr6r7r8r9Fr:Tr;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrOcSrTrU)rrZrrTriggerExecutionr\rr]r^r!r!r"ra8rbz/Triggers.run.._speakeasy_parse_responserc RunTriggerrerfricSrqrrrsrur!r!r"rwYrxzTriggers.run..ryrzrrXrSrrrr!)%r rrrFrrRunTriggerRequestrrrRunTriggerGlobalsrr(rDr~rrrrr rrrr rrtrrrrrrrrrrrr rr(r,r-r.r6r7rrr@rFr8rrr~rarr_rrr!r!r"runrz Triggers.run"__name__ __module__ __qualname__propertyr#r&rstrintrrrfloathttpxTimeoutrr[rtriggers_triggercreateparamsrInteractionParamrrr rrrtriggers_triggerupdateTriggerUpdateStatusrrrrrr!r!r!r"r!s^    &      <     -  !rc@eZdZdeddfddZdS)rsdkr/NcCz||_t|jd|_t|jd|_t|jd|_t|jd|_t|jd|_t|jd|_t|j d|_ dSNr,) _sdkrto_raw_response_wrapperrrrrrrrr rr!r!r"__init__s z TriggersWithRawResponse.__init__rrrrr r!r!r!r"rrc@r)r%rr/NcCrr ) r rto_streamed_response_wrapperrrrrrrrr r!r!r"r , z&TriggersWithStreamingResponse.__init__rr!r!r!r"r%rr%c@r), AsyncTriggerscCrr)AsyncTriggersWithRawResponserr!r!r"r#r$zAsyncTriggers.with_raw_responsecCrr)"AsyncTriggersWithStreamingResponserr!r!r"r&r$z%AsyncTriggers.with_streaming_responseNr'r(r)r*r+r,r-r.r/c sd}d} t} d} |} ||} | dur|jj} | dur| }n||| }tj||||d}t| \}} |j d4iddddd|d| d |d d d d dd ddddd| d|dtj |jj j dd|jj ddd| }| tkr|jjtur|jj} ntjdtddddd dd } d}t| tjr| gd!f}d"d#}t|j|pd$d%dt|jj tjddt|d&d'd(}|j||d)d*|d+k|d,IdH}|d-kr>td.d/g|jr|IdHz ||IdHWn+ty}zt|jjd0|jjd1t |||IdHWYd}~nd}~ww|d+kr!tj!ntj"}t#t$|||d2|t ||jjd1|jjd0d3Sz||IdHWStyr}zt|jjd0|jjd1t |||IdHWYd}~dSd}~ww)5r0Nr1r2r3r4r5r6r7r8r9Fr:Tr;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrOct|ddrttj|ddSt|ddr&t|IdH}td||t|ddr._speakeasy_parse_responsercrdasyncrfricSrqrrrsrur!r!r"rw-rxz$AsyncTriggers.list..ryrzrrXrS _async_hooksrrrrrgrr{r async_hooksr!)%r rrrFrrrrr_build_request_asyncrrr(rDr~rrrrr rrrr do_request_asyncrtrareadrraise_parse_error_asyncrrrAsyncStreamedAPIResponseAsyncAPIResponserrrr!r!r"r                        zAsyncTriggers.listrrrrrrrrrc  sd} d}t}d}| }|| }|dur|jj}|dur|} n|| |} tj|tj|||t |tj |||ddt |\}}|jd6iddddd| d |d d d d d dd ddddd|d| dtj|jjjdd|jjdfddddd|}|tkr|jjtur|jj}nt jdt ddd d!d d"d#}d}t|t jr|gd$f}d%d&}t|j| pd'd(dt|jjtjddt|d)d*d+}|j||d,d|d-k|d.IdH}|d/krSt d0d1g|jr.|IdHz ||IdHWn+t y-}zt !|jj"#d2|jj"#d3t$|||IdHWYd}~nd}~ww|d-kr6t j%nt j&}t't(|||d4|t$||jj"#d3|jj"#d2d5Sz||IdHWSt y}zt !|jj"#d2|jj"#d3t$|||IdHWYd}~dSd}~ww)7rNrrr2rr4r5r6r7r8r9Tr:r;r<r=r>r?r@rArBrCrDrcrrrr!rr!r"rwrz&AsyncTriggers.create..rErFrGrHrIrJrKrLrMrOcrrUrrZrrrrrr]r^r!r!r"rarz7AsyncTriggers.create.._speakeasy_parse_responsercrrrfricSrqrrrsrur!r!r"rwrxryrzrrXrSrrrrr!))r rrrFrrrrrrrrrrrrrr(rDr~rrrr rrrr rrtrrrrrrrr r!rrrr!rr"rZs"                          zAsyncTriggers.createrrc d}d}t}d} |} ||} | dur|jj} | dur| }n|||}tj||d} t| \} } |j d4iddddd|d|d | d d d d dd ddddd| d|dtj |jj j dd|jj ddd| }|tkr|jjtur|jj}ntjdtddddd dd }d}t|tjr|gd!f}d"d#}t|j|pd$d%dt|jj tjddt| d&d'd(}|j||d)d*| d+k|d,IdH}| d-krr?r@rArBrCrDrErFrGrHrIrJrKrLrMrOcrrU)rrZrr rrrr]r^r!r!r"ra_rz7AsyncTriggers.delete.._speakeasy_parse_responsercrrrfricSrqrrrsrur!r!r"rwrxz&AsyncTriggers.delete..ryrzrrXrSrrrrr!)%r rrrFrrrrrrrrr(rDr~rrrrr rrrr rrtrrrrrrrr r!rrrr!r!r"r                        zAsyncTriggers.deletec r$)5rNrr2r3r4rr6r7r8r9Fr:Tr;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrOcrrUr#r^r!r!r"rarz4AsyncTriggers.get.._speakeasy_parse_responsercrrrfricSrqrrrsrur!r!r"rwrxz#AsyncTriggers.get..ryrzrrXrSrrrrr!)%r rrrFrrrrrrrrr(rDr~rrrrr rrrr rrtrrrrrrrr r!rrrr!r!r"rr%zAsyncTriggers.getrrc sd} d} t} d} |} ||}|dur|jj}| dur| } n|| | } tj||tj||ddt | \}} |j d6iddddd| d | d d d d d dd ddddd| d|dtj |jj jdd|jjdfddddd|}| tkr|jjtur|jj} ntjdtddd d!d d"d#} d}t| tjr| gd$f}d%d&}t|j| pd'd(dt|jjtjddt|d)d*d+}|j||d,d|d-k|d.IdH}|d/krJtd0d1g|jr%|IdHz ||IdHWn+ty$}zt |jj !d2|jj !d3t"|||IdHWYd}~nd}~ww|d-kr-t j#nt j$}t%t&|||d4|t"||jj !d3|jj !d2d5Sz||IdHWSty~}zt |jj !d2|jj !d3t"|||IdHWYd}~dSd}~ww)7rNrrr2rr4rr6r7r8r9Tr:r;r<r=r>r?r@rArBrCrDrcrrrr!rr!r"rwrz&AsyncTriggers.update..rErFrGrHrIrJrKrLrMrOcrrUr#r^r!r!r"rarz7AsyncTriggers.update.._speakeasy_parse_responsercrrrfricSrqrrrsrur!r!r"rwrxryrzrrXrSrrrrr!)'r rrrFrrrrrrrrrrr(rDr~rrrrr rrrr rrtrrrrrrrr r!rrrr!rr"rFs                         zAsyncTriggers.updaterrc sd}d} t} d} |} ||} | dur|jj} | dur| }n||| }tj||||d}t| \}} |j d4iddddd|d| d |d d d d dd ddddd| d|dtj |jj j dd|jj ddd| }| tkr|jjtur|jj} ntjdtddddd dd } d}t| tjr| gd!f}d"d#}t|j|pd$d%dt|jj tjddt|d&d'd(}|j||d)d*|d+k|d,IdH}|d-kr>td.d/g|jr|IdHz ||IdHWn+ty}zt|jjd0|jjd1t |||IdHWYd}~nd}~ww|d+kr!tj!ntj"}t#t$|||d2|t ||jjd1|jjd0d3Sz||IdHWStyr}zt|jjd0|jjd1t |||IdHWYd}~dSd}~ww)5rNrr2r3r4rr6r7r8r9Fr:Tr;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrOcrrU)rrZrrrrrr]r^r!r!r"raBrz@AsyncTriggers.list_executions.._speakeasy_parse_responsercrrrfricSrqrrrsrur!r!r"rwcrxz/AsyncTriggers.list_executions..ryrzrrXrSrrrrr!)%r rrrFrrrrrrrrr(rDr~rrrrr rrrr rrtrrrrrrrr r!rrrr!r!r"rr"zAsyncTriggers.list_executionsc r$)5rNrr2rr4rr6r7r8r9Fr:Tr;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrOcrrU)rrZrrrrrr]r^r!r!r"rarz4AsyncTriggers.run.._speakeasy_parse_responsercrrrfricSrqrrrsrur!r!r"rwrxz#AsyncTriggers.run..ryrzrrXrSrrrrr!)%r rrrFrrrrrrrrr(rDr~rrrrr rrrr rrtrrrrrrrr r!rrrr!r!r"rr%zAsyncTriggers.runrr!r!r!r"rs^    )      ?     0  $rc@r)rrr/NcCrr ) r rasync_to_raw_response_wrapperrrrrrrrr r!r!r"r + rz%AsyncTriggersWithRawResponse.__init__rrrrr r!r!r!r"r* rrc@r)rrr/NcCrr ) r r"async_to_streamed_response_wrapperrrrrrrrr r!r!r"r E rz+AsyncTriggersWithStreamingResponse.__init__r'r!r!r!r"rD rr)'__doc__basesdkrrrcrrrrrrr r r r r rtypes.triggersrrrrrrutils.unmarshal_json_responserrtypingrrrrrrrr%rrrr!r!r!r"sB k