ZNSrSSKrSSKrSSKrSSKrSSKJr SSKJ r SSK J r SSK Jr SSK J r SSK Jr SSK Jr SS KJr SS KJr SS KJr SSKrS rS r"SS\R25r"SS\R25r\R8"S/SQ5r"SS\5rSr Sr!"SS\5r""SS\"5r#"SS\"5r$"SS\RJ5r&"S S!\5r'g)"z/Manage and stream build logs from Cloud Builds.N) 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$)NoLogsBucketException6c0>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__8s DC /4__name__ __module__ __qualname____firstlineno__r__static_attributes__ __classcell__rs@rr r 6s 55rr c(^\rSrSrU4SjrSrU=r$)4DefaultLogsBucketIsOutsideSecurityPerimeterException=c4>[[U] [5 gN)rr"r6DEFAULT_LOGS_BUCKET_IS_OUTSIDE_SECURITY_PERIMETER_TEXT)rrs rr=DefaultLogsBucketIsOutsideSecurityPerimeterException.__init__?s > OPrrrr s@rr"r"=sQQrr"Response)statusheadersbodyc$\rSrSrSrSrSrSrg)RequestsLogTailerGz9LogTailer transport to make HTTP requests using requests.c8[R"5Ulgr%)creds_requests GetSessionsessionrs rrRequestsLogTailer.__init__Js!,,.DLrc0URRSUSSRU50S9n[URUR UR 5$![RRan[R"SU-5eSnAff=f)NGETRangez bytes={0}-)r*zFailed to connect: %s) r2requestformatr( status_coder*contentr rRequestExceptionapi_exceptionsCommunicationError)rurlcursorresponsees rRequestRequestsLogTailer.RequestMsK%% w (;(;F(CD&Fh h**H,<,N>N OO    / /K  - -.E.I JJKsAAB7BB)r2N)rrrr__doc__rrCrrrrr-r-GsA/Krr-cSSKJn UR5$![a& [RR [ 5 gf=f)zReturn a GCL LogTailer.rtailingN)googlecloudsdk.api_lib.loggingrH ImportErrorroutPrintLOG_STREAM_HELP_TEXT LogTailerrGs rGetGCLLogTailerrOVs@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 rIsCB4ArXcs\ ]] }} %--'',, --  $ $ %----88 99 rcB\rSrSrSrSrSrSrSr\4Sjr S Sjr S r g ) TailerBasemz"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---> )rVALUES accessibility screen_readerGetBoolresub)rtextras r_ValidateScreenReader TailerBase._ValidateScreenReaderrs=%%33AAIIKM VVGR && KrcUR(a2U(a*URRUR55 ggg)z@Testing Hook: This method enables better verification of output.N)rKrLrstrip)rres r _PrintLogLineTailerBase._PrintLogLineys( xxD hhnnT[[]#xrc[R"5up#URURX R55 g)zDPrint a pretty starting line to identify start of build output logs.Nr GetTermSizerjcenterOUTPUT_LINE_CHARrrwidth_s r_PrintFirstLineTailerBase._PrintFirstLine~s/**,HEszz%)>)>?@rc[R"5up#URURX R5S-5 g)z@Print a pretty ending line to identify end of build output logs. Nrmrqs r_PrintLastLineTailerBase._PrintLastLines4**,HEszz%)>)>?$FGrrN)r^) rrrrrELOG_OUTPUT_BEGINrprfrjrtrxrrrrrZrZms,*,$ !1A HrrZcx\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) rOtailerbuild_id project_id timestamprKbuffer_window_secondslog_urlstopis_cb4a)rbuildId projectIdrlogUrlrKrs 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. )rrrrrKr)idr createTimerrX)clsrWrKs 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)rrr9rrrTailLogsrrtrf text_payloadrjrxrrparent log_filter output_logsoutputres 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) r9rrrrr FetchLogsrtrf textPayloadrjrxrs rrLGCLLogTailer.Prints $ + +t + GF 028nn]]282$  || /06!%$..171J ""f>K   ' '(:(: ;d  r) rrrrrKrrrr)rrrrrErr)r classmethodrKrrrrLrrrrr|r|sDJ :: " #$& P rr|c\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) r- transport _StorageUrlr?rdebugr@rKr)rbucketobjrKs rrGCSLogTailer.__init__ sG&(DN,DHII#dhh./DKHDIrc[RRRR 5nSn[RR R R5(aSnURX1US9$)Nz0https://storage.{universe_domain}/{bucket}/{obj}z5https://storage.mtls.{universe_domain}/{bucket}/{obj})universe_domainrr) rr_corerGet context_awareuse_client_certificaterbr9)rrrr url_patterns rrGCSLogTailer._StorageUrlsl '',,<<@@BODK&&==EEGGKk   'C  AArc(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/r^z{object}log-{id}.txt)objectr)rrrK) logsBucketr startswithlensplitr9r)rrWrK 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))codecountrrwiz2Reading GCS logfile: 429 (server is throttling us)iiXz&Reading GCS logfile: got {0}, retryingr))rrCr?r@r=r>r)rrrxr9rr+rtr DecoderfrjriwarningLOG_OUTPUT_INCOMPLETEdictr* HttpError)ris_lastresdecodedr*s rPollGCSLogTailer.PollCs  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)rrrrr3s rrGCSLogTailer.Tails8ii iik jjmiii IIdIrcSUlgr)rr3s rrGCSLogTailer.Stops DIrc"URSS9 g)zPrint GCS logs to the console.TrN)rr3s rrLGCSLogTailer.PrintsIIdIr)r@rKrrr?N)F)rrrrrErrr)rrrrKrrrrrLrrrrrrsPJ3&)jjA #%%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)rr=rr:r"rr>)rrBs rrunThreadInterceptor.runs^  kkm  # # # NO  , ,nns&A=A AA=-A88A=)rr) rrrrrErrrrr 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)rT) CollectionrREGISTRYCreaterrDEFAULT_REGIONrrprojects_locations_buildsrr+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).) rr)rLstrrrrrr)rrWr 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. )rKz7Streaming logs from GCL: requested logging mode is {0}.z2Not streaming logs: requested logging mode is {0}.N)r)rrQloggingr BuildOptionsLoggingValueValuesEnumNONESTACKDRIVER_ONLYCLOUD_LOGGING_ONLYrrrrinfor9r|BuildStatusValueValuesEnumQUEUEDWORKINGrrstartrjoinr)rrrKrWrstatusesrts 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)rrQr rr r r r rrrrrr9r|rL)rrrWrs rPrintLogCloudBuildClient.PrintLog)sN MM) $E ==EMM11 ""99>> ""99JJ ""99LL:  ))%0j    ""99JJ ""99LL#  hhGNN --  !"))%0j hh?FF --  !"jr)rrrr)NNFr) rrrrrErrrrrKrrrrrrrrs6O ! -,.0#&''5nrr)(rE collectionsrc threadingrapitools.base.pyrr=!googlecloudsdk.api_lib.cloudbuildrrIrgooglecloudsdk.corerrrgooglecloudsdk.core.consoler googlecloudsdk.core.credentialsr r0googlecloudsdk.core.utilr rMr&Errorr r" namedtupler(rr-rOrXrZr|rThreadrrrrrr(s6  9=1*#*)7F-:65J,,5Q:;K;KQ  ! !*.K L K K HH:w:wtX:Xv ((.QvQr