eUdZddlZddlZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z mZddlmZddlZddlZddlmZddlmZddlmZddlmZdd lmZdd lmZeZej8d kDr ej:Zej<Zgd Zgd Z d@dejBfdZ" dAde ejBddfdZ#dee$e$fde$fdZ%dejLjNde$fdZ(dee$e$fde$fdZ)de$fdZ*de+de$fdZ,de$de$fdZ-e$Z.ee/d<e$Z0ee/d<e e e$e$fe e$e$fe e$e$ffZ1ee/d <e e0e1fZ2ee/d!<e ee$e ee$e$fe$ffZ3ee/d"<d#e3de$fd$Z4de$fd%Z5d&e$ddfd'Z6 dBd(ejnd)e ejLjpd&ejrfd*Z:d+e ejLjpfd,Z;d-Zde$fd0Z?de$fd1Z@de$fd2ZAd3ZBd4ZCd5ZDd6ZEd7ZFd8ZGd9ZHd:ZId;ee$efdee$effd<ZJd=ZKd>ZLd?ZMy)Cz.BQ CLI frontend formatting library for Python.N)AnyDictListOptionalTupleTypeUnioncast) TypeAlias)utils) bq_api_utils) bq_consts)bq_error) bq_id_utils)bq_processor_utils)) updateTimeschedulerunTime scheduleTimeparamsendTime dataSourceIddestinationDatasetIdstate startTimename)rrr obj_formatcddg}|dk(r!ttj|dy |dk(r"ttj|ddy td|d |) zPrints obj in a JSON format according to the format argument. Args: obj: The object to print. obj_format: The format to use: 'json' or 'prettyjson'. json prettyjson),:) separatorsT) sort_keysindentz#Invalid json format for printing: 'z', expected one of: N)printr!dumps ValueError)objr json_formatss (platform/bq/frontend/utils_formatting.py_print_formatted_json_objectr/0s],',6 $**SZ 01\! $**SD 34  | %  flag_formatreturnc "|sy|jdr|djdr|ddjd|ddjd|ddjdd}|dvrt|| nTtd |ddjdd |ddjdd |ddjdd |jdr|djdr}|ddjd|ddjdd}|dvrt|| nz@Please create a Service Principal in your directory for appId: 'z(', and perform role assignment to app: 'z0' to allow BigQuery to access your Azure data. )getr/r)) connectionr1r,s r..maybe_print_manual_instructions_for_connectionrAFs  ^^Ez%0445GH&'9:>>{K&'9:>>{K '(:;?? M C ,,"3;?  2377 D 2377 D 2377 E  ^^Ez%044\B&|488Eu%l377 C C,,"3;?  -11+> -11*=   ^^GG!4!8!8$" w  # #$B Cw'++J7  C ,,"3;? !%%&DE!%%j1   ~~gw'++J7!'*..}= C,,"3;? !%%j1!%%m4  r0labelscg}|jD]\}}|d|}|j|g dj|S)z(Format a resource's labels for printing.r$ )itemsextendjoin)rB result_lineskeyvalue label_strs r._format_labelsrLsF,LLNjc5&I $# <  r0tablec(|dd|dd|dS)N projectIdr$ datasetId.tableId)rMs r._format_table_referencerTs& K K I r0tagsc|jDcgc]\}}dj||}}}dj|Scc}}w)z&Format a resource's tags for printing.z{}:{}rD)rEformatrG)rUrIrJrHs r._format_resource_tagsrXs@?Czz|L|e'..e,|,L <  MsAcg}|D]\}|dddk(r |ddd}n|dd}d|dd|j}|dddk(r|dz }|j|g^d j|S) zReturns a string with standard_sql_fields. Currently only supports printing primitive field types and repeated fields. Args: standard_sql_fields: A list of standard sql fields. Returns: The formatted standard sql fields. typetypeKindARRAYarrayElementTypez|- r: z (repeated)rD)lowerrFrG)standard_sql_fieldslinesfield field_typeentrys r._format_standard_sql_fieldsres %"e V}Z G+=!34Z@j=,j =**:*:*< =E V}Z G+ }e LL%# 5 r0secscTtjdtj|S)Nz%d %b %H:%M:%S)timestrftime localtime)rfs r. format_timerks ')= >>r0 json_stringctjj|d}|tjdddz j}t|S)zAConverts google.protobuf.Timestamp formatted string to BQ format.z%Y-%m-%dT%H:%M:%S.%fZi)datetimestrptime total_secondsrk)rlparsed_datetimesecondss r.,format_time_from_proto_timestamp_json_stringrtsM%%..*/x00q!< < K K M' W r0StringReference ResourceType ConditionsResourceTypeAndConditions DatasetAccessaclc Ztjt}|D]}|j}t t t t f|jdd}t t t t t t ff|jdd}t t t t f|jdd}t t |jdd}|rK|dj|jdd|jd d |jd |rt t t t f|jd}|jd D]A}|d |zdzdfj|jdd|jd C|r>t tjjdi|} |dj| t t t t f|jdd} |r%tt|jdk7rtj d|zig| r=||t#| j%fj'|j||dfj'|jddddd} g} | j%D]`\}} |j|dfd}|s| jd| z| jdj)dt+|Dbt+|j%D]\\}} }|| vr| jd| |zn| jd|z| jdj)dt+|D| sl| jd| jdj)dt-| j%Ddj)| S) z*Format a server-returned ACL for printing.viewNdatasetroutinerole)VIEWrSrOr$rPrQrR targetTypeszAll z in DATASETrS)ROUTINErS conditionrnz"Invalid ACL returned by server: %sOwnersWritersReaderszAuthorized Views)OWNERWRITERREADERrz%s:z, c3&K|] }d|z ywz %sNrS.0ms r. zformat_acl..!s$IAVaZc3&K|] }d|z ywrrSrs r.rzformat_acl..(s"G!6A:rz condition:rDc32K|]\}}d|d|yw)z r^NrS)rrIrJs r.rzformat_acl..,s! 7*#u!$U+ 7s) collections defaultdictlistcopyr rstrpopappendr?rApiClientHelperRoutineReferencelenvaluesrBigqueryInterfaceErrortuplerErFrGsorteddict)rz acl_entriesrdr|r}r~rdataset_referencetargetroutine_referenceroriginal_rolesrHrmemberss r. format_aclrsd#e JJLE S#X &$ 7 8D4T#s(^+,eii 4.HIG4S>599Y#=>G UYYvt, -D *$$ XXk "DHH[$9488I;N P tCH~w{{9/EFKK .&FVOm3R78??"%%k2!%%k2  /   % % 6 6 A A- ''(9:tCH~uyyd'CDi Selln-.!3-- 03 6B   T5!2345<$? tY ~%."667%$,' "Gvg"GGH*+ )) $Y 5 5 7  %@ <  r0czddttffd dj|jdgS)zFormat a schema for printing.r2c g}|D]}d|z}|jdddk7rdnd}|d|dd |jddj}d |vr |d |d zz }n5d |vr1d |vr|d|d d|d dz }n |d |d zz }d|vr |d|dzz }|jdddk7r|d|djdz }|j||zd|vs|j|d|dz|S)z5Print all fields in a schema, recurring as necessary.z| rZSTRINGRECORD|+z- rr^ maxLengthz(%s) precisionscale(, ) roundingModez options(rounding_mode="%s")modeNULLABLE (fieldsrn)r?r_rrF)rr(rarbprefixjunctionrd print_fieldss r.rz#format_schema..print_fields7s: Ev~f &(3x?Sh  - ))FH % + + -e   5-.. %  e  {!3U7^D D% 6U;/0 0% U " 1U>5JK K% 6: &* 4 E&M//133 ll6E>" U  \%/6A:>?/0 Lr0rDr)r)rrrGr?)schemars @r. format_schemar4s4S : < 8R 89 ::r0 print_formatc(|dvrtd|y)N)showrr|materialized_viewmake table_replicazUnknown format: )r+)rs r.validate_print_formatrWs$ \; <<r0 formatterreference_typec t||tjjk(r|dk(r|j d|j d|dk(rV|j d|j d|j d|j d|j d y5y5|tjj k(r(|dk(r|j d |j d y5|tjj k(r|dk(r|j d |dk(r|j d |j d d|v}|xsd|v}|r|j dd|vr|j dd|vr|j dd|vr|j dd|vr|j dy5y5y5|tjjk(r}|dk(rD|j d|j d|j d|j d|dk(r.|jD]}|dk7s |j |fy5y5|tjjk(ry|dk(r$tD]}|dk7s |j |fy5|dk(rtD]}|j |fy5|dk(r'tD]}|tvs |j |fy5y5|tjjk(r4|j d|j d |j d!y5|tjjk(r|j d"y5|tjjk(rD|dk(r|j d#|dk(r(|j d$d%|vr|j dy5y5y5|tjjk(r|dk(r"|j d&|j d'|dk(rg|j d(d)|vr|j d*d+|vr|j d,d-|vr|j d.d/|vr|j d0y5y5y5|tjj k(r|dk(s|dk(r|j d1y5y5|tjj"k(r%|dk(r"|j d2|j d3|dk(rd4}|c|dd6k(r|j d7d8}nG|dd9k(r|j d:d8}n+d;|vr|j d<nd=|vr|j d>|r|j d?|j d d%|vr|j dd@|vr|j d|dAk(r|j dB|dCk(r|j dD|dEk(r|j dFy5y5|tjj$k(r)|j t'|jy5|tjj(k(rOdG}t*j,j.t*j0j2vrg|dH}|j |y5|tjj4k(r|j dIy5|tjj6k(r|j dJy5|tjj8k(r|j dy5|tjj:k(r|j dKy5t=dL|j>)MaConfigure a formatter for a given reference type. If print_format is 'show', configures the formatter with several additional fields (useful for printing a single record). Arguments: formatter: TableFormatter object to configure. reference_type: Type of object this formatter will be used with. print_format: Either 'show' or 'list' to control what fields are included. object_info: Resource dict to format. Raises: ValueError: If reference_type or format is unknown. r)jobId)Job TypeState Start TimeDurationr) User Email)Bytes Processed) Bytes Billed) Billing Tier)Labels)rO) friendlyName)rP) Last modifiedACLsrU resource_tags)TagsdefaultEncryptionConfiguration) kmsKeyNamerZ)rlinkedDatasetSource)Source datasetmaxTimeTravelHours)Max time travel (Hours))r) displayName)r)rrr) messageText) messageTime)severity) nextPageToken)Id Model Typer Creation Time)rrFeature Columns Label ColumnsrrExpiration TimeencryptionConfiguration)r Routine TypeLanguagerLast Modified Time) Is Remote)rrr Signature DefinitionrrremoteFunctionOptions)Remote Function Endpoint ConnectionUser Defined Context sparkOptions) rRuntime VersionContainer Image Properties Main File URI Main Class PyFile URIsJar URIs File URIs Archive URIs pythonOptions) Entry PointPackagesexternalRuntimeOptions)rrContainer Memory Container CPU)rFilter PredicateGranteesrr)rRr)rTime PartitioningClustered FieldsTNr)rSchemar ExpirationFEXTERNAL)rrr Total URIsr snapshotDefinition) Base TableSnapshot TimeStampcloneDefinition)r Clone TimeStamp) rr Total Rows Total Bytesr rrTotal Logical BytesTotal Physical Bytes resourceTagsr|)Queryr)rEnable RefreshRefresh Interval MsLast Refresh Timer)rrr Source TableSource Last Refresh TimeReplication Interval SecondsReplication StatusReplication Error) r slotCapacitytargetJobConcurrencyignoreIdleSlots creationTimermultiRegionAuxiliaryeditionautoscaleMaxSlotsautoscaleCurrentSlotsmaxSlots scalingModereservationGroup) r slotCountplan renewalPlanrcommitmentStartTimecommitmentEndTimer#r$ isFlatRate)rjobTypeassignee)rr descriptionrrZ hasCredential propertieszUnknown reference type: ) rrr JobReference AddColumnsProjectReferenceDatasetReferenceTransferConfigReferencekeysTransferRunReference$_COLUMNS_TO_INCLUDE_FOR_TRANSFER_RUN'_COLUMNS_EXCLUDED_FOR_MAKE_TRANSFER_RUNTransferLogReferenceNextPageTokenReferenceModelReferencerRowAccessPolicyReferenceTableReferenceEncryptionServiceAccountrReservationReferencebq_flags AlphaFeaturesRESERVATION_GROUPSALPHArJCapacityCommitmentReferenceReservationAssignmentReferenceReservationGroupReferenceConnectionReferencer+__name__) rrr object_infoadd_tagsrIcolumn use_defaultshared_columnss r.configure_formatterrScs( %{22???v:&  v?+/0,-,-;'  44EEEv>* *+44EEEv>*v ;';&h;_ ;h Y' )[ 8_- ; Y' + -01  ,9: -!$44LLLv9%+,,-:&v!!## &=   v &$44IIIv8& V    y )9  8&fY'9  8& A B   y )9 44III )* )* '44KKK +,44CCCvJKv  #k 1_- 244EEEv >*v  !K /  ; &   K '   "[ 0   1ER44MMMv!7 "844CCCv NOvk  v & (   ? +  J .   M + ![ 0   C D + -   @ A    ;' "k 1_- ; &Y'v:&** &   '44MMM k..01244III N00HNN4H4HH  n( 33OOO     $ $ C CD8944NNN #44HHH  ^5L5LN OOr0 object_typecF|tjjk(r t|S|tjjk(r t |S|tjj k(r t|S|tjjk(r t|S|tjjk(r t|S|tjjk(r t|S|tjjk(r t|S|tjj k(r t#|S|tjj$k(r t'|S|tjj(k(r t+|S|tjj,k(r|St/|tjj0r t3|St/|tjj4r t7|St/|tjj8r t;|St/|tjj<r t?|S|tjj@k(r tC|StEd|)zformat_transfer_log_inforC issubclassrDformat_reservation_inforIformat_capacity_commitment_inforJ"format_reservation_assignment_inforKformat_reservation_group_inforLformat_connection_infor+)rNrTs r.format_info_by_typergsK//<<< ; ''k11BBB { ++k11BBB { ++k11@@@ [ ))k11@@@ [ ))k11BBB { ++k11JJJ ( 55k11III &{ 33k11FFF #K 00k11FFF #K 00k11JJJ ;..CC #{ ;;;..JJ +; 77;..MM .k ::;..HH ) 55k11EEE !+ .. +? @@r0cX|j}tj|}|jt ||j di}tj ||d<|dd|d<d|vr|d|d<|ddk(r tj|d |d<d |vrYt|d d z }d |vr6t|d d z |z }ttj||d<t||d<tj |}|r||d<|j di}d|vr|d|d<d|vr|d|d<d|vr|d|d<|j di}d|vrt#|d|d<d|vr|d|d<d|vr|d|d<d |vrt |d |d!<d"|vrt |d"|d#<d$|vrt |d$|d%<d&|vr|d&|d'<d(|vr|d(|d)<|d(d*k(rd+|d,<d-|vrt |d-|d.<|S#tj$r d |d<YwxYw)/zuPrepare a job_info for printing. Arguments: job_info: Job dict to format. Returns: The new job_info. statisticsrstatusrr user_emailrDONESUCCESSFAILURErr)rsrrz Session IdquerytotalBytesProcessedrtotalBytesBilledr billingTierr configurationrBrnumDmlAffectedRowsz Affected RowsddlOperationPerformedzDDL Operation PerformedddlTargetTablezDDL Target TableddlTargetRoutinezDDL Target RoutineddlTargetRowAccessPolicyzDDL Target Row Access PolicyddlAffectedRowAccessPolicyCountz$DDL Affected Row Access Policy Count statementTypezStatement TypeASSERTT AssertiondefaultConnectionStatszDefault Connection Stats)rrConstructObjectReferenceupdaterr?GetJobTypeNamebq_client_utilsRaiseIfJobErrorr BigqueryErrorintrro timedeltark GetSessionIdrL) job_inforesult referencestatsstartduration_seconds session_id query_statsconfigs r.rWrWs ==?& 99&A)--Y **\2 &%)88@&8$W-&/V!,/F< G_"%%f-!fWoE k" #d *EEU9-.5=x11:JKLfZ&u-F<"..x8*%F< '2&+k) +,A BF ;&();k!(7F> ::or *& %fX&67F8[()*>?F? +(34K(LF $%$!%k2B&C!DF ;&#' 4F(G#HF  ;.-1./.F )*'+55@)6F 12 #*?;F ?#x/ f[,)-,-*F %& -c  ! !"!fWo"s H H)(H)c|j}tj|}|jt ||S)zPrepare a project_info for printing. Arguments: project_info: Project dict to format. Returns: The new project_info. )rrrrr) project_inforrs r.rXrXs7    & 99&A)--Y -r0cbi}|dd|d<d|d<d|vr|d|d<d|vrt|d|d<d |vrtt|d d z |d <d |vrtt|d d z |d <d|vrt|d|d<d|vrt|d|d<d|vr |dd|d<|S)zPrepare a model for printing. Arguments: model_info: Model dict to format. Returns: A dictionary of model properties. modelReferencemodelIdrr modelTyperBrr"rorexpirationTimerfeatureColumnsr labelColumnsrrr)rLrkrre) model_infors r.r[r[ s &,-i8&,&J%k2F< %j&:;F8z!) J~ &'$.F?# + J' ()D0!F # ;#$!F z!9>"F?*,%&?@NF< -r0c |d}|dk(rdj|t|dS|dk(rU|ddDcgc]#}dj|d t|d %}}dj|d j|S|Scc}w) zConverts a routine data type to a pretty string representation. Arguments: data_type: Routine data type dict to format. Returns: A formatted string. r[r\z{}<{}>r]STRUCT structTyper{} {}rrZrrWformat_routine_data_typerG) data_type type_kindrb struct_fieldss r.rr2s #)' ??+I6H,IJ H|,X66E uV}&>uV}&MN6 ??9dii &> ??  s(Bc |dDcgc]#}dj|dt|d%}}djdj|Scc}w)zConverts a routine table type to a pretty string representation. Arguments: table_type: Routine table type dict to format. Returns: A formatted string. columnsrrrZz TABLE<{}>rr) table_typerPrs r.format_routine_table_typerJscy) )&nnVF^%=fVn%MN)     DIIg. //  s(AcZd|vrt|d}nJ|jddk(rd}n3|dk(rd|vrt|d}n|dk(r|jddk(rd}d |vrId }d |vr|d d z}|d k(r d|vr|dsdj||d dSdj||d SS)aTConverts a routine argument to a pretty string representation. Arguments: routine_type: The routine type of the corresponding routine. It's of string type corresponding to the string value of enum cloud.bigquery.v2.Routine.RoutineType. argument: Routine argument dict to format. Returns: A formatted string. dataType argumentKindANY_TYPEzANY TYPETABLE_VALUED_FUNCTION tableType ANY_TABLEz ANY TABLErrr AGGREGATE_FUNCTION isAggregatez {}{} {} {}z NOT AGGREGATEz{}{} {})rr?rrW) routine_typeargument display_type argument_modes r.format_routine_argument_inforZs8+HZ,@AL||N#z1L..;(3J,Xk-BCL-- ,,~ &+ 5L xM v&,m,, X %'  &)<  mXf-=| LL r0cTi}dd|d<d|d<jdd|d<d }jd }jd }d vr.d }d jdjfd|D}|rdj|t|}|rdj|t |}|s|sd vr||d<dvrd|d<dvrt t ddz |d<dvrt t ddz |d<d|d<dvr3d|d<dd|d<dd|d <djd!d|d"<d#vr6d#d$|d%<d#jd&|d'<jd(|d)<d*vrsd*jd+|d,<d*jd-|d.<d*jd/|d0<d*jd1|d <d*jd2|d3<d4vr d4}gd5}|D]\}} ||vs |||| <|S)6zPrepare a routine for printing. Arguments: routine_info: Routine dict to format. Returns: A dictionary of routine properties. routineReference routineIdr routineTyperlanguagerrz() returnTypereturnTableType argumentsz({})rc3<K|]}td|yw)rN)r)rr routine_infos r.rz&format_routine_info..s% ) )m)Dh O)sz{} -> {}rdefinitionBodyrr"rorlastModifiedTimerNorrYesendpointrr@ruserDefinedContextrr entryPointrpackagesrimportedLibraries LibrariesrruntimeVersionrcontainerMemoryr containerCpurruntimeConnectionmaxBatchingRowszMax Batching Rowsr) )r@r)rr)containerImager)r4r) mainFileUrir) mainClassr) pyFileUrisr)jarUrisr)fileUrisr) archiveUrisr)r?rWrGrrrkr) rr signature return_typereturn_table_type argument_list spark_optionsoptions spark_key result_keys ` r.r\r\s &01+>&,' 6&#'' B7&)  .+"&&'89L  -M   )  I !!+K8I!!,->?I%+*E#F;%'(89F<|#) L ()D0F?<'#. L+ ,-4$F  & ,F;)56M)N*F %&((?@NF<%12I%J%N%Nb&F !" $(9,GF=%o6:::FF:'**+>?F;- ,-E F J J!F "..F!G!K!K"F ++CDHHF?((@AEEF<#//G"H"L"L#F |# 0M G") : m #*95z") -r0ci}|dd|d<|d|d<dj|d|d<d |vrt|d |d <d |vrt|d |d <|S) zPrepare a row access policy for printing. Arguments: row_access_policy_info: Row access policy dict to format. Returns: A dictionary of row access policy properties. rowAccessPolicyReferencepolicyIdrfilterPredicaterrgranteesrr"rrr)rGrt)row_access_policy_infors r.r]r]s &'(BCJO&,56GH& yy!7 !CD&--J~.F?11#O12$F   -r0cv|j}tj|}|jt |d|vrt t |ddz |d<d|vrt|d|d<d|vrt|d|d<d|vrt|d|d <d |vr |d d |d <d |vrz|d |d <|d dk(rAd|vr=|dd}ttjjjdi||d<|d dk(r!d|vr|d}d|vr|d|d<d|vr|d|d<d|vr|d|d<|S)zPrepare a dataset_info for printing. Arguments: dataset_info: Dataset dict to format. Returns: The new dataset_info. rroraccessrrBrrrrrrZrLINKEDr sourceDatasetrr externalDatasetReferenceexternal_sourcezExternal sourcer@rrrrS)rrrrrrkrrrLrXrrrr8Create) dataset_inforrsource_datasetexternal_dataset_references r.rYrYs    & 99&A)--Y 6!) F% &'$.F?x 01F6N %fX&67F8v*6.+ABF6N%/!"BCF< vF^F6N f~!&;v&E34_En!$  % % 6 6 = = O O"f f~#(Bf(L#)*D#E 8 8$> %  ! 3 39,G|V#(./C(DF $% -r0c|j}tj|}|jt |d|vrt t |ddz |d<d|vrt|d|d<d|vr|d|d<d|vr|d|d <d |vr|d |d <d |vr|d |d <d|vr|d|d<d|vr|d|d<d|vr|d|d<d|vr|d|d<d|vr|d|d<d|vr|d|d<d|vrt t |ddz |d<d|vrt|d|d<d|vrt|d|d<d |vrd!|d vr |d d!|d"<nd#|d"<g}d$|d vr|d d$}|jd%|zd&|d vr&t |d d&}|jd'|fz|r |d"xxd(d)j|d*z cc<d+|vr!d,|d+vrd)j|d+d,|d-<d!|vr)|d!|d.<d/|vrd0|d/vr |d/d0|d1<d2|vrhd0|d2vra|d2d0|d1<d3|d2vr |d2d3|d4<d5|d2vr |d2d5|d6<d7|d2vr+|d2d7d8k7r t t |d2d7dz |d9<d:|vr{t|d:d;|d<<t t |d:d=dz |d><|d:d?|d@<dA|d:vr t t |d:dAdz |dB<dC|d:vr|d:dCdD|dE<|d!dFk(rdG|vrt|dGdH|dI<dJ|vrdK|dJvr |dJdK|dK<dL|vr|dLdM|dN<t|dLdO|dP<dQ|vr|dQdM|dN<t|dQdR|dS<|S)Tz}Prepare a table_info for printing. Arguments: table_info: Table dict to format. Returns: The new table_info. rrorrrnumBytesrnumTotalLogicalBytesrnumLongTermLogicalByteszLong-Term Logical BytesnumActiveLogicalByteszActive Logical Bytes numPartitionszTotal PartitionsnumTotalPhysicalBytesrnumActivePhysicalByteszActive Physical BytesnumLongTermPhysicalByteszLong-Term Physical BytesnumTimeTravelByteszTime Travel BytesnumRowsrrr rBrrrtimePartitioningrZrDAYrbz field: %s expirationMszexpirationMs: %drrr clusteringrrrr|rprmaterializedView enableRefreshrrefreshIntervalMsrlastRefreshTime0rtableReplicationInfo sourceTablerreplicationIntervalMsrreplicationStatusrreplicatedSourceLastRefreshTimerreplicationErrormessagerr externalDataConfiguration sourceUrisr rrr baseTableReferencer  snapshotTimerr cloneTimer)rrrrrrkrrrLrXrrGrTrrt) table_inforr extra_infopartitioning_field expiration_mss r.rZrZ*s ?? & 99&A)--Y 6!) F% &'$.F?$VH%56F86":.F=v%$*+A$BF !&((./H(IF $%&%+,C%DF !"!'!8F &%+,C%DF !"'&,-E&FF "#6))/0J)KF %&V#"()=">F &!),F<&s62B+C'Dt'KLF< %fX&67F8v*6.+ABF6N6! *++$*+=$>v$Ff !$)f !J&+,,!"45g> &889 233&!34^DEm*m-==> ! *0E%GG!V6,''#'99VL-A(-K#Lf   vF^F6N Gvf~5vw/fWoV#6:L3M(M127;fWo F#56 6#)*<#=o#N '9 : :(./A(B ) $% v&89 9'():;sB&1 )*+<= > E' "#'6 ' ( 7 f^03 f+,-DE F M0f +,&,,B%C &f !" +f5K.L L-8 -.5    . )* v&<= =&,-C&D ' '"#f~# $ ." . / = | 6) &!:; ;!";<\JF<V#!"678LMF<#O#$^4$F  & !"345IJF< L !+.!F  -r0cDi}|jD] \}}|||< |S)zPrepare transfer config info for printing. Arguments: transfer_config_info: transfer config info to format. Returns: The new transfer config info. rE)transfer_config_inforrIrJs r.r^r^s0 &(..0jc5F3K1 -r0cDi}|jD] \}}|||< |S)zPrepare transfer log info for printing. Arguments: transfer_log_info: transfer log info to format. Returns: The new transfer config log. r)transfer_log_inforrIrJs r.r`r`s0 &%++-jc5F3K. -r0cVi}|jD]\}}|tvs|||<|S)zPrepare transfer run info for printing. Arguments: transfer_run_info: transfer run info to format. Returns: The new transfer run info. )rEr<)transfer_run_inforrIrJs r.r_r_s9 &%++-jc5 22fSk. -r0ci}|jD]h\}}|dk(rYtj|\}}}tjj j |||}|j||<d|||<jdt|jvrd|d<dt|jvrd|d<dt|jvrd|d<dt|jvr|d|d <|jdd nd |d <d t|jvr;d |d vr"|d d |d<d|d<d|d vr |d d|d<|jd d |S)zPrepare a reservation for printing. Arguments: reservation: reservation to format. Returns: A dictionary of reservation properties. r)rOlocation reservationIdrrr!Falser# concurrencyr Nz0 (auto) autoscaler'r%r& currentSlots) rErParseReservationPathrrrDr__str__rr:r)rVrrIrJ project_idrreservation_idrs r.rbrbs &%%'jc5 f}  . .u 5+j(N--BBIIJi%%'fSkfSk(4 .. F>d6;;=11 'F 4 #66%,F !"d6;;=))%+M%:F !" JJ}d#%/F !"D''VK(($*;$7 $Cf !(+f $% 6+. .*0*=n*M&' JJ{D! -r0reservation_groupci}|jD]h\}}|dk(rYtj|\}}}tjj j |||}|j||<d|||<j|S)zPrepare a reservation group for printing. Arguments: reservation_group: reservation group to format. Returns: A dictionary of reservation group properties. r)rOrreservationGroupId)rErParseReservationGroupPathrrrKrr#)r&rrIrJr$rreservation_group_idrs r.reres &%++-jc5 f}  3 3E :1j(0--GGNN1Oi %%'fSkfSk. -r0ci}|jD]h\}}|dk(rYtj|\}}}tjj j |||}|j||<d|||<jdt|jvrd|d<dt|jvrd|d<|S)zPrepare a capacity commitment for printing. Arguments: capacity_commitment: capacity commitment to format. Returns: A dictionary of capacity commitment properties. r)rOrcapacityCommitmentIdr*rr#r) rErParseCapacityCommitmentPathrrrIrr#rr:)capacity_commitmentrrIrJr$rcapacity_commitment_idrs r.rcrc$s &'--/jc5 f}  5 5e <3j(2  % % A A H H"#9 I %%'fSkfSk0 V[[]++F;4 #66%,F !" -r0ci}|jD]j\}}|dk(r[tj|\}}}}tjj j ||||}|j||<f|||<l|S)zPrepare a reservation_assignment for printing. Arguments: reservation_assignment: reservation_assignment to format. Returns: A dictionary of reservation_assignment properties. r)rOrrreservationAssignmentId)rErParseReservationAssignmentPathrrrJrr#) reservation_assignmentrrIrJr$rr%reservation_assignment_idrs r.rdrdEs &*002jc5 f}  8 8 ?Fj(N,E  % % D D K K"*&? L %%'fSkfSk3 -r0ci}|jD]\}}|dk(rYtj|\}}}tjj j |||}|j||<d|dk(rtt|dz |d<|tjvr;tjj||d<tj||d<|||<|jdd |d<|S) zPrepare a connection object for printing. Arguments: connection: connection to format. Returns: A dictionary of connection properties. r)rOr connectionIdrrorrZr4r3F)rErParseConnectionPathrrrLrr#rkrrCONNECTION_PROPERTY_TO_TYPE_MAPr?r!r*)r@rrIrJr$r connection_idrs r.rfrfbs &$$&jc5 f},;,O,O -)j(M--AAHH Ii%%'fSk " " +CJ,= >f_ "BB B)IIMM fVn"ZZ.f\fSk#'$'NN?EB& -r0)r!)N)rN)N__doc__rror!sysrhtypingrrrrrrr r typing_extensionsr table_formatterrEclientsr rr rrrrcollections_abc version_infoabcServicer<r= FormatTyper/rArrLrrBrTrXrefloatrkrtru__annotations__rvrwrxryrrrTableFormatter ReferenceCustomPrintFormatrSrgrWrXr[rrrr\r]rYrZr^r`r_rbrercrdrfrSr0r.rJs4 FFF',$fOO/    ($"+O'-3)).?CZ%i&:&:;Z Zz!4S>!c!  & & 5 5!S#X!3! .?e??cc!  i eCHouS#Xc3hOP IP',\:-E'F9FS%S#X0C*D%D EF yFF!MF!cF!R ;S ;F = = =17 ]P--]P44>>?]P--]P@ -A";#>#>#H#HI-A`HV "J30 0S 0 'C'T]@0+\{|"   ,^CH~ #s(^8B:r0