%SrSSKJr SSKrSSKJr SSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKrSSKJrJr SSKJr SSKJr SSKJr SS KJr SS KJr SS KJr SS KJr S rSr Sr!\ RD"S5r#\RHSSj5r%"SS\RL5r'\RP"SS55r)\RP"SS55r*"SS\RV5r,g)zClasses and utils for Storage diagnostics. Storage diagnostics are a bunch of tests that can be run to diagnose issues with the storage system. ) annotationsN)MutableMapping)DictList)errors)utils)execution_utils)log) console_io)progress_tracker)filesCLOUDSDK_STORAGE_THREAD_COUNTCLOUDSDK_STORAGE_PROCESS_COUNTzN/Az%.*following URLs matched no objects.*c#t# [R"5nSv [R"5nX2- X'g7f)a#A context manager that records the time it takes to run a block of code. Args: key: The key to use in the result dictionary. result: The dictionary to store the result in. The time taken to run the block of code will be stored in this dictionary with the given key. Yields: None N)time)keyresultt0t1s =lib/googlecloudsdk/command_lib/storage/diagnose/diagnostic.py time_recorderr5s) yy{" yy{"&+s68c\rSrSrSrSrg)DiagnosticIgnorableErrorGz;Ignorable Exception thrown during the diagnostic execution.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rrrrGsCr"rcF\rSrSr%SrS\S'S\S'SrS\S 'S S jrS rg) DiagnosticOperationResultKzResult of a operation performed as part of a diagnostic. Attributes: name: The name of the operation. result: The result of the operation. payload_description: The description of the payload used for running this operation. strnamezDict[any, any]rNz str | Nonepayload_descriptionc[R"5nURS5 URSRUR55 UR (a*URSRUR 55 URSRUR 55 UR5$)NzDiagnostic Operation Result Name: {} zPayload Description: {} z Result: {} )ioStringIOwriteformatr'r(rgetvalue)selfouts r__str__!DiagnosticOperationResult.__str__Zs ++-CII-.IIl!!$)),-  ii+2243K3KLMIIn##DKK01 <<>r"rreturnr&) rrrrr __annotations__r(r2r!rr"rr$r$Ks$ ) $(z(r"r$cF\rSrSr%SrS\S'S\S'SrS\S 'S S jrS rg) DiagnosticResultdzResult of a diagnostic execution. Attributes: name: The name of the diagnostic. operation_results: The results of the operations performed as part of this diagnostic. metadata: Additional metadata associated with the diagnostic. r&r'zList[DiagnosticOperationResult]operation_resultsNzDict[any, any] | Nonemetadatac[R"5nURS5 URSRUR55 UR (a*URSRUR 55 URS5 UR H nUR[U5S-5 M" UR5$)NzDiagnostic Result r*z Metadata: {} z Operation Results:  ) r+r,r-r.r'r;r:r&r/)r0r1operation_results rr2DiagnosticResult.__str__ss ++-CII#$IIl!!$)),- }} ii '' 67II&' 22 ii$%,-3 <<>r"rr4) rrrrr r6r;r2r!rr"rr8r8ds$ )44$(( !( r"r8c\rSrSrSrSr\\RSSj55r Sr \RS5r Sr Sr SSS jjrSS jrSSS jjrSS jrS rSSjrSrg) DiagnosticzBase class for storage diagnostics. This class provides a framework for writing diagnostics. Subclasses can override the pre-processing, diagnostic and post-processing steps as needed. The execute method is the entry point for running the diagnostic. Ncg)zThe name of the diagnostic.Nrr0s rr'Diagnostic.names r"cJ[RR5Ulg)zPre-processing step for the diagnostic. This method is called before the diagnostic is run. Implementing child classes can override this method to perform actions necessary for running diagnostics like file creation, setting configurations etc. N)osenvironcopy _old_env_varsrDs r _pre_processDiagnostic._pre_processs*Dr"cg)z|Runs the diagnostic. This method is called after the pre-processing step and is expected to perform the actual diagnostic. NrrDs r_runDiagnostic._runs r"cJURbUR[lgg)zPost-processing step for the diagnostic. This method is called after the diagnostic is run. Implemeneting child classes can override this method to perform clean up actions, aggregating metrics, etc. N)rJrGrHrDs r _post_processDiagnostic._post_processs" %%%bj&r"c[RRSURS35 [R "5 UR 5 UR5 UR5 [RRSUR35 SSS5 g![a/n[R"URSU35 SnANySnAff=f!UR5 f=f!,(df  g=f)zExecutes the diagnostic.zRunning diagnostic: z...z Diagnostic execution failed: NzFinished running diagnostic: ) r statusPrintr'r RaisesKeyboardInterruptrKrNrerrorrQ)r0es rexecuteDiagnostic.executesJJ+DII;c:;  0 0 2   jj6tyykBC 3 2 &C TYYK=aSABBC  3 2sBC; B*%> ?sOA D/;DAD 1DD/ D D D,(D/,D//E=%E88E=c<[U5[RU'g)zSets the environment variable to the given value. Args: variable_name: Name of the environment variable. variable_value: Value of the environment variable. N)r&rGrH)r0 variable_namevariable_values r_set_env_variableDiagnostic._set_env_variables!$N 3BJJ}r"cSSUUS/n[R"XCS9upVU(a[SRXU55eg)zRuns the gcloud cp command. Args: source_url: Source url for the cp command. destination_url: Destination url for the cp command. in_str: The input to pass to the gcloud cp command. Raises: DiagnosticIgnorableError: If the cp command fails. storagecpz--verbosity=debug)in_strz0Failed to copy objects from source {} to {} : {}N)r run_gcloudrr.)r0 source_urldestination_urlrargs_errs r_run_cpDiagnostic._run_cpsV    D  d 2FA $ < C C3   r"cSSUUS3/n[R"U5upEU(aX[RU5(a[R "SUSUS35 g [R "SUSUSU35 g g ) z5Diagnostic._generate_random_string..*s=A  f**V]]:V=O=OOPPsAA)joinrh)r0lengths rrl"Diagnostic._generate_random_string!s& 77v r")rJrer4)i)rsz List[int]rtrruintr5bool)r~r&ranyr)rr&rr&)rr&rr&r5None)rrr5r&)rrrrr rJpropertyabcabstractmethodr'rKrNrQrYr{rrrrrlr!rr"rrArAs-    +  & D$$ ))) )  )V44 &H r"rA)rr&rzMutableMapping[str, float]r5r)-r __future__rrcollections.abcr contextlib dataclassesr+rGrrerrirtypingrr"googlecloudsdk.command_lib.storager+googlecloudsdk.command_lib.storage.diagnosergooglecloudsdk.corer r googlecloudsdk.core.consoler r googlecloudsdk.core.utilr rcrrPLACEHOLDER_METRIC_VALUEcompilercontextmanagerrErrorr dataclassr$r8ABCrArr"rrs # *  5=/#28879  jj,  "Dv||D 0 4nnr"