|NSrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKrSSK r SSK J r SSK Jr SS KJr SSKJ r SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSKrSrSr"SS\ R<5r"SS\ R<5r \RB"S/SQ5r""SS\#5r$Sr%Sr&"SS\#5r'"SS\'5r("S S!\'5r)"S"S#\RT5r+"S$S%\#5r,g)&z/Manage and stream build logs from Cloud Builds.)absolute_import)division)print_function)unicode_literalsN) exceptions)cloudbuild_util)common)log) properties) resources)console_attr_os)requests)encodingz To live stream log output for this build, please ensure the grpc module is installed. Run: pip install grpcio and set: export CLOUDSDK_PYTHON_SITEPACKAGES=1 a The build is running, and logs are being written to the default logs bucket. This tool can only stream logs if you are Viewer/Owner of the project and, if applicable, allowed by your VPC-SC security policy. The default logs bucket is always outside any VPC-SC security perimeter. If you want your logs saved inside your VPC-SC perimeter, use your own bucket. See https://cloud.google.com/build/docs/securing-builds/store-manage-build-logs. c(^\rSrSrU4SjrSrU=r$)NoLogsBucketException:c0>Sn[[U] U5 g)Nz8Build does not specify logsBucket, unable to stream logs)superr__init__)selfmsg __class__s -lib/googlecloudsdk/api_lib/cloudbuild/logs.pyrNoLogsBucketException.__init__<s DC /4__name__ __module__ __qualname____firstlineno__r__static_attributes__ __classcell__rs@rrr:s 55rrc(^\rSrSrU4SjrSrU=r$)4DefaultLogsBucketIsOutsideSecurityPerimeterExceptionAc4>[[U] [5 gN)rr&r6DEFAULT_LOGS_BUCKET_IS_OUTSIDE_SECURITY_PERIMETER_TEXT)rrs rr=DefaultLogsBucketIsOutsideSecurityPerimeterException.__init__Cs > OPrrrr$s@rr&r&AsQQrr&Response)statusheadersbodyc$\rSrSrSrSrSrSrg)RequestsLogTailerKz9LogTailer transport to make HTTP requests using requests.c8[R"5Ulgr))creds_requests GetSessionsessionrs rrRequestsLogTailer.__init__Ns!,,.DLrc0URRSUSSRU50S9n[URUR UR 5$![RRan[R"SU-5eSnAff=f)NGETRangez bytes={0}-)r.zFailed to connect: %s) r6requestformatr, status_coder.contentrrRequestExceptionapi_exceptionsCommunicationError)rurlcursorresponsees rRequestRequestsLogTailer.RequestQsK%% w (;(;F(CD&Fh h**H,<,N>N OO    / /K  - -.E.I JJKsAAB7BB)r6N)rrr r!__doc__rrGr"rrrr1r1KsA/Krr1cSSKJn UR5$![a& [RR [ 5 gf=f)zReturn a GCL LogTailer.rtailingN)googlecloudsdk.api_lib.loggingrL ImportErrorr outPrintLOG_STREAM_HELP_TEXT LogTailerrKs rGetGCLLogTailerrSZs@6     GGMM&' s-AAc6UR(aURR(a)[URRR5$URR(a)[URRR 5$g)z/Separate CB4A requests to print different logs.F)optionsclusterboolname anthosCluster membership)builds rIsCB4Ar\gs\ ]] }} %--'',, --  $ $ %----88 99 rcB\rSrSrSrSrSrSrSr\4Sjr S Sjr S r g ) TailerBaseqz"Base class for log tailer classes.z REMOTE BUILD OUTPUT -c[RRRR 5nU(a[ R "SSU5$U$)z2Modify output for better screen reader experience.z---> )r VALUES accessibility screen_readerGetBoolresub)rtextres r_ValidateScreenReader TailerBase._ValidateScreenReadervs=%%33AAIIKM VVGR && KrcUR(a2U(a*URRUR55 ggg)z@Testing Hook: This method enables better verification of output.N)rOrPrstrip)rris r _PrintLogLineTailerBase._PrintLogLine}s( xxD hhnnT[[]#xrc[R"5up#URURX R55 g)zDPrint a pretty starting line to identify start of build output logs.Nr GetTermSizerncenterOUTPUT_LINE_CHARrrwidth_s r_PrintFirstLineTailerBase._PrintFirstLines/**,HEszz%)>)>?@rc[R"5up#URURX R5S-5 g)z@Print a pretty ending line to identify end of build output logs. Nrqrus r_PrintLastLineTailerBase._PrintLastLines4**,HEszz%)>)>?$FGrrN)rb) rrr r!rILOG_OUTPUT_BEGINrtrjrnrxr|r"rrrr^r^qs,*,$ !1A Hrr^cx\rSrSrSrS\R S4Sjr\\R4Sj5r Sr Sr S r S rg) GCLLogTailerzBHelper class to tail logs from GCL, printing content as available.NFc[5UlXlX lX0lXPlSUlX@lSUlX`l g)NF) rStailerbuild_id project_id timestamprObuffer_window_secondslog_urlstopis_cb4a)rbuildId projectIdrlogUrlrOrs rrGCLLogTailer.__init__s;"#DKMONH!"DLDILrc zU"URURURURU[ U5S9$)zBuild a GCLLogTailer from a build resource. Args: build: Build resource, The build whose logs shall be streamed. out: The output stream to write the logs to. Returns: GCLLogTailer, the tailer of this build's logs. )rrrrrOr)idr createTimerr\)clsr[rOs r FromBuildGCLLogTailer.FromBuilds9 //""|| u  rcUR(dgUR(agSRURS9nSRURURS9nUR (aSRURS9nURR U/X RS9nUR5 UH/nURUR5nURU5 M1 URS 5 UR(a(URS RURS 95 g) z9Tail the GCL logs and print any new bytes to the console.Nprojects/{project_id}rzslogName="projects/{project_id}/logs/cloudbuild" AND resource.type="build" AND resource.labels.build_id="{build_id}")rrzdlabels."k8s-pod/tekton.dev/taskRun"="{build_id}" OR labels."k8s-pod/tekton_dev/taskRun"="{build_id}")r)rz( BUILD FINISHED; TRUNCATING OUTPUT LOGS z"Logs are available at [{log_url}].)r)rrr=rrrTailLogsrrxrj text_payloadrnr|rrparent log_filter output_logsoutputris rTailGCLLogTailer.Tails* ;;  yy $ + +t + GF:;A6!%4==="{timestamp}" AND resource.labels.build_id="{build_id}")rrrz(labels."k8s-pod/tekton.dev/taskRun"="{build_id}" OR labels."k8s-pod/tekton_dev/taskRun"="{build_id}") AND timestamp>="{timestamp}")rrasc)rorder_byrN) r=rrrrr FetchLogsrxrj textPayloadrnr|rs rrPGCLLogTailer.Prints $ + +t + GF 028nn]]282$  || /06!%$..171J ""f>K   ' '(:(: ;d  r) rrrrrOrrrr)rrr r!rIr r-r classmethodrOrrrrPr"rrrrrsDJ :: " #$& P rrc\rSrSrSrSr\R4SjrSr \ \R4Sj5r S Sjr SrS rS rS rg ) GCSLogTailerizBHelper class to tail a GCS logfile, printing content as available.z (possibly incomplete) c[5UlURX5Ul[R "SUR-5 SUlX0lSUlg)NzGCS logfile url is rF) r1 transport _StorageUrlrCr debugrDrOr)rbucketobjrOs rrGCSLogTailer.__init__ sG&(DN,DHII#dhh./DKHDIrcSn[RRRR 5(aSnUR XS9$)Nz-https://storage.googleapis.com/{bucket}/{obj}z2https://storage.mtls.googleapis.com/{bucket}/{obj})rr)r rc context_awareuse_client_certificaterfr=)rrr url_patterns rrGCSLogTailer._StorageUrlsAAK&&==EEGGHk   V  55rc(UR(d [5eURnSnURU5(aU[U5SnSU;aUnSnOUR SS5upVUS- nSR UUR S9nU"UUUS9$) a,Build a GCSLogTailer from a build resource. Args: build: Build resource, The build whose logs shall be streamed. out: The output stream to write the logs to. Raises: NoLogsBucketException: If the build does not specify a logsBucket. Returns: GCSLogTailer, the tailer of this build's logs. zgs://N/rbz{object}log-{id}.txt)objectr)rrrO) logsBucketr startswithlensplitr=r)rr[rO log_stripped gcs_prefix log_bucketlog_object_dir log_objects rrGCSLogTailer.FromBuilds    ! ####LJz**!#j/"23l ,jn%1%7%7Q%?"zn'.. 88/J    rcURRURUR5nUR S:Xa[R"S5 gUR S:Xa.[R"S5 U(aUR5 gUR S:XdUR S:Xa[R"SRUR [UR5S 95 URS :XaUR5 U=R[UR5- sl[R"UR5nUbUR!U5nUR#UR%S 55 U(aUR5 gUR S :Xa9[R&"S 5 U(aURUR(5 gUR S:abUR S:aR[R&"SRUR 55 U(aURUR(5 g[+UR,5nUR US'[R."XBRUR5e![R a U(aegf=f)a)Poll the GCS object and print any new bytes to the console. Args: is_last: True if this is the final poll operation. Raises: api_exceptions.HttpError: if there is trouble connecting to GCS. api_exceptions.CommunicationError: if there is trouble reaching the server and is_last=True. Niz3Reading GCS logfile: 404 (no log yet; keep polling)iz7Reading GCS logfile: 416 (no new content; keep polling)z0Reading GCS logfile: {code} (read {count} bytes))codecountrr{iz2Reading GCS logfile: 429 (server is throttling us)iiXz&Reading GCS logfile: got {0}, retryingr-)rrGrCrDrArBr-r rr|r=rr/rxrDecoderjrnrmwarningLOG_OUTPUT_INCOMPLETEdictr. HttpError)ris_lastresdecodedr.s rPollGCSLogTailer.PollEs  NN " "488T[[ 9c zzS iiEF  zzS iiIJ    zzSCJJ#- iiBIIzzSXXJ01    kkS]"k)g  ,,W5 -.    zzS kkFG  D667  zzSSZZ#- kk:AA#**MN  D667 3;;G GH  " "7HHdhh ??q  , ,    s0J66KKcUR(d9UR5 [R"S5 UR(dM9URSS9 g)z;Tail the GCS object and print any new bytes to the console.rTrN)rrrrr7s rrGCSLogTailer.Tails8ii iik jjmiii IIdIrcSUlgr)rr7s rrGCSLogTailer.Stops DIrc"URSS9 g)zPrint GCS logs to the console.TrN)rr7s rrPGCSLogTailer.PrintsIIdIr)rDrOrrrCN)F)rrr r!rIrr r-rrrrOrrrrrPr"rrrrrsOJ3&)jj6 #%%NE@N rrc2^\rSrSrSrU4SjrSrSrU=r$)ThreadInterceptoriz'Wrapper to intercept thread exceptions.cD>[[U] 5 XlSUlgr))rrrtarget exception)rrrs rrThreadInterceptor.__init__s T+-KDNrcUR5 g![Ra4nURS:Xa[ 5UlSnAgXlSnAgSnAf[R anXlSnAgSnAff=f)Ni)rrArr>r&rrB)rrFs rrunThreadInterceptor.runs^  kkm  # # # NO  , ,nns&A=A AA=-A88A=)rr) rrr r!rIrrr"r#r$s@rrrs/  rrc\\rSrSrSrS SjrSrSr\R4Sjr Sr S r g) CloudBuildClientizGClient for interacting with the Cloud Build API (and Cloud Build logs).NcU=(d [R"5UlU=(d [R"5UlX0lX@lgr))rGetClientInstanceclientGetMessagesModulemessages support_gclpolling_interval)rrrrrs rrCloudBuildClient.__init__s: ?O==?DKC A A CDM",rcBUR5S:XaB[RRSUR[ R URS9nURRRURRUR5S95$)zGet a Build message. Args: build_ref: Build reference. Expects a cloudbuild.projects.locations.builds but also supports cloudbuild.projects.builds. Returns: Build resource zcloudbuild.projects.buildsz$cloudbuild.projects.locations.builds) collection projectsId locationsIdbuildsId)rX) Collectionr REGISTRYCreaterrDEFAULT_REGIONrrprojects_locations_buildsGetr+CloudbuildProjectsLocationsBuildsGetRequest RelativeName)r build_refs rGetBuildCloudBuildClient.GetBuilds!==$$++;((%44<< ,!i ;; 0 0 4 4 AA'') B + ,,rcJ[RRS[UR5-S-5 URU;aCUR U5n[ R"UR5 URU;aMCU(aUR5 U$)ahChecks whether a log tailer should be stopped. Args: build: Build object, containing build status build_ref: Build reference, The build whose logs shall be streamed. log_tailer: Specific log tailer object working_statuses: Valid working statuses that define we should continue tailing Returns: Build message, the completed or terminated build. z1Waiting for build to complete. Polling interval: z second(s).) r r-rPstrrrrrr)rr[r log_tailerworking_statusess rShouldStopTailer!CloudBuildClient.ShouldStopTailersJJH../02?@A ,,* *mmI&e jj&&' ,,* *oo LrcURU5nUR(aURRURRR R URRR RURRR R4;a[RX2S9nGOURRURRR RURRR R4;a^UR(aM[R"SRURR55 [RX2S9nO;[R"SRURR55 SnURR R"nUR$UR&/nSnU(a#[)UR*S9nUR-5 UR/X1UU5nU(a)UR15 UR2b UR2eU$)aStreams the logs for a build if available. Regardless of whether logs are available for streaming, awaits build completion before returning. Args: build_ref: Build reference, The build whose logs shall be streamed. out: The output stream to write the logs to. Raises: NoLogsBucketException: If the build is expected to specify a logsBucket but does not. Returns: Build message, the completed or terminated build. )rOz7Streaming logs from GCL: requested logging mode is {0}.z2Not streaming logs: requested logging mode is {0}.N)r)rrUloggingr BuildOptionsLoggingValueValuesEnumNONESTACKDRIVER_ONLYCLOUD_LOGGING_ONLYrrrr infor=rBuildStatusValueValuesEnumQUEUEDWORKINGrrstartrjoinr)rrrOr[rstatusesrts rStreamCloudBuildClient.Streams" MM) $E ==EMM11 ""99>> ""99JJ ""99LL:  ))%)9j    ""99JJ ""99LL#     hhHOO --  !"))%)9j hhCJJ --  !"j}}""88H A :?? 3aggi  ! !%J"2 4Effh  kk LrcURU5nUR(aURRURRR R URRR RURRR R4;a[RU5nOURRURRR RURRR R4;aO[R"SRURR55 [RU5nO;[R"SRURR55 SnU(aUR5 gg)zPrint the logs for a build. Args: build_ref: Build reference, The build whose logs shall be streamed. Raises: NoLogsBucketException: If the build does not specify a logsBucket. z6Printing logs from GCL: requested logging mode is {0}.z.Logs not available: build logging mode is {0}.N)rrUr rr r rrrrrr rr=rrP)rrr[rs rPrintLogCloudBuildClient.PrintLog+sN MM) $E ==EMM11 ""99>> ""99JJ ""99LL:  ))%0j    ""99JJ ""99LL#  hhGNN --  !"))%0j hh?FF --  !"jr)rrrr)NNFr) rrr r!rIrrrr rOrrr"rrrrrs6O ! -,.0#&''5nrr)-rI __future__rrrr collectionsrg threadingrapitools.base.pyrrA!googlecloudsdk.api_lib.cloudbuildrrMr googlecloudsdk.corer r r googlecloudsdk.core.consoler googlecloudsdk.core.credentialsrr4googlecloudsdk.core.utilrrQr*Errorrr& namedtupler,rr1rSr\r^rrThreadrrrrrr+s6&%'  9=1*#*)7F-:65J,,5Q:;K;KQ  ! !*.K L K K HH:w:wtV:Vr ((.QvQr