!SrSSKJr SSKJr SSKJr SSKrSSKrSSKJrJ r J r J r J r J r SSKJr SSKrSSKJr SS KJr SSKrSSKrSSKrSS KJr S r\R6rS \ \R:S \S\ \S\ \ \ /S4S\ \ \/\ 4S\ \S\ \4Sjr!\!\l"SS\RD5r#"SS\RH5r%g)z#Bigquery Client library for Python.)absolute_import)division)print_functionN)AnyCallableDictListOptionalTuple)flags)http)model)utilsr num_retriesreq_typesleeprandurimethodc [XX#XEU/UQ70UD6up[U R5S:Xa[R"U R S55n [ U [5(aYSU S;aPU SSn SU ;aBSU;a<SUS;a3USS [R"S5 [UUUUUUU/UQ70UD6upX4$) aConditionally retries an HTTP request. If the original request fails with a specific permission error, retry it once without the x-goog-user-project header. Args: http: Http object to be used to execute request. num_retries: Maximum number of retries. req_type: Type of the request (used for logging retries). sleep: Function to sleep for random time between retries. rand: Function to sleep for random time between retries. uri: URI to be requested. method: HTTP method to be used. *args: Additional arguments passed to http.request. **kwargs: Additional arguments passed to http.request. Returns: resp, content - Response from the http request (may be HTTP 5xx). izutf-8messageerrorz'roles/serviceusage.serviceUsageConsumerheadersx-goog-user-projectz7Retrying request without the x-goog-user-project header) (_ORIGINAL_GOOGLEAPI_CLIENT_RETRY_REQUESTintstatusjsonloadsdecode isinstancedictlogginginfo) r rrrrrrargskwargsrespcontentdata err_messages $platform/bq/clients/bigquery_http.py _RetryRequestr-!sB; $V>BFL-$  ::gnnW- .D$)tG}"<M),k 2k A  #8F9>[TU]"S0UD6 XlX lg)N)super__init__r2r3)selfr2r3kwds __class__s r,r7BigqueryModel.__init__ds  GtJ,r.r path_params query_params body_valuereturnc>SU;a UR(aURUS'SU;aSUS'SR[R"5US/5nUR 5US'UR (aUR US'[ RR(a[ RRUS'[TU])XX45$)aUpdates outgoing request. Headers updated here will be applied to only requests of API methods having JSON-type responses. For API methods with non-JSON-type responses, headers need to be set in BigqueryHttp.Factory._Construct. Args: headers: dict, request headers path_params: dict, parameters that appear in the request path query_params: dict, parameters that appear in the query body_value: object, the request body as a Python object, which must be serializable. Returns: A tuple of (headers, path_params, query, body) headers: dict, request headers path_params: dict, parameters that appear in the request path query: string, query part of the request URI body: string, the body serialized in the desired wire format. r2cookie user-agent rx-goog-request-reason) r2joinbq_utils GetUserAgentstripr3bq_flagsREQUEST_REASONvaluer6request)r8rr<r=r> user_agentr:s r,rMBigqueryModel.requestos:l"tzz**gh7" gl8002GL4IJKJ&,,.GL '+'<'[R"SUS5 [TU] X5$)a6Convert the response wire format into a Python object. Args: resp: httplib2.Response, the HTTP response headers and status content: string, the body of the HTTP response Returns: The body de-serialized as a Python object. Raises: googleapiclient.errors.HttpError if a non 2xx response is received. z)Response from server with status code: %sr)r$r%r6response)r8r(r)r:s r,rQBigqueryModel.responses( LL+KcN +K  +K  T#s(^T#s(^S# 56 +K`+8,,+s+v++r.r0c^\rSrSrSrS\4U4Sjjr\S\S\S4Sj5r S S\ \ RS \ \ 4U4S jjjrS rU=r$) BigqueryHttpz%Converts errors into Bigquery errors.bigquery_modelcn>[TU]"U0UD6 [R"SUSUS5 Xlg)Nz)URL being requested from BQ client: %s %sr)r6r7r$r%_model)r8rcr&r9r:s r,r7BigqueryHttp.__init__s9  Gd#d# LL3T(^T!W!Kr.r?).rac^U4SjnU$)zDReturns a function that creates a BigqueryHttp with the given model.c>SU;a0US'USRSS5n[R"5n[R U5[R U5;a(SR X2/5nUR 5USS'SUS;aDTR(a3[R"STR5 TRUSS'SUS;an[RR(aO[R"S[RR5 [RRUSS'Tn[U/UQ70UD6$) NrrBrCrDrz)Setting x-goog-user-project header to: %srEz+Setting x-goog-request-reason header to: %s)getrGrHrYlowerrFrIr3r$r%rJrKrLra)r&r9rN bq_user_agentcaptured_modelrcs r, _Construct(BigqueryHttp.Factory.._ConstructsD $ Y ?&&|R8j++-m = !:)> >XX}9: (2(8(8(:Y % tI 6-- 7  + + 2@1P1PY-. "i 8%%++ 9  # # ) ) 4<3J3J3P3PY/0%n    r.r5)rcrns` r,FactoryBigqueryHttp.Factorys (T r.r rc>Uc[n[TU] UUS9$![RR aPnUR RURUR5 [R"U5 SnAgSnAf[R[4a n[R"U5 SnAgSnAff=f)N)r r)#_NUM_RETRIES_FOR_SERVER_SIDE_ERRORSr6executegoogleapiclienterrors HttpErrorrf _log_responser(r)bq_client_utilsRaiseErrorFromHttpErrorr[ HttpLib2ErrorIOErrorRaiseErrorFromNonHttpError)r8r rer:s r,rtBigqueryHttp.executes 6  ;+w#   # # - -3 !!!&&!))4//22$$g .6221556s!CABC B;;C)rfrS)rTrUrVrWrXr0r7 staticmethodrrpr r[Httprrtr]r^r_s@r,raraso- !# !/#/#$//n'+#'6 X]] #6C=66r.ra)&rX __future__rrrrr$typingrrrr r r abslr rur http_requestrr[rJrGclientsrryrs_retry_requestrrrrYfloatr- JsonModelr0 HttpRequestrar5r.r,rs*&% ==0!,&'#,8+F+F(9 8== !99sm9 HeWd]+ , 9 8SE5L) * 9 # 9 SM9x, M+EOOM+dY6<++Y6r.