SrSSKJr SSKJr SSKJr SSKrSSKrSSKJr SSKJ r SSK J r SS K J r SS K Jr SS KJr SS KJr S rSrSSjrSrSSjrSrSrSrg)z%Client for interaction with Dataplex.)absolute_import)division)unicode_literalsN) storage_api) storage_util)apis)waiter) exceptions) resources)yamlc0[R"SS5$Ndataplexv1)rGetClientInstance+lib/googlecloudsdk/api_lib/dataplex/util.pyrr!   D 11rc0[R"SS5$r)rGetMessagesModulerrrGetMessageModuler%rrc[RRURSS9n[R "U[ 5R5n[R"UUSRUR55UUS9$)z=Waits for the given google.longrunning.Operation to complete.z&dataplex.projects.locations.operations) collectionzWaiting for [{0}] to finish)sleep_mspre_start_sleep_ms) r REGISTRYParsenamer CloudOperationPollerrprojects_locations_operationsWaitForformat RelativeName) operationresourcerr operation_refpollers rWaitForOperationr))s$$**nn!I+-  & &!#AA &  #**=+E+E+GH+  rc [USS5(a\UR[URR 55VVs/sHup#URR X#S9PM snnS9$gs snnf)Nlabels)keyvalue)additionalProperties)getattr LabelsValuesortedr+itemsAdditionalProperty)dataplex_resourceargsr,r-s r CreateLabelsr6<s T8T""  ( ( %T[[%6%6%89  :   ) ) < < = :   )   s%A0 cURS5(d[R"U5$U=(d [R"5n[ R RU5nURU5n[R"USS9n[R"UR55$![a+n[R"SR!U55UeSnAff=f)adReads an object's content from GCS. Args: object_url: Can be a local file path or the URL of the object to be read from gcs bucket (must have "gs://" prefix). storage_client: Storage api client used to read files from gcs. Returns: A str for the content of the file. Raises: ObjectReadError: If the read of GCS object is not successful. zgs://zutf-8)encodingzSUnable to read file {0} due to incorrect file path or insufficient read permissionsN) startswithr load_pathr StorageClientrObjectReferenceFromUrl ReadObjectio TextIOWrapperloadread Exceptionr BadFileExceptionr#) object_urlstorage_clientclient object_refbytes_iowrapperes rr>r>Is   w ' ' >>* %%  8[668&++33J?*   ,Hx':G 99W\\^ $$   % % "F:.    s+A B55 C*?&C%%C*cbSRS[URS5555$)z)Converts snake case string to camel case.c3V# UHupUS:aUR5OUv M! g7f)rN) capitalize).0indwords r SnakeToCamel..is+4)#7doo,4s')_)join enumeratesplit)arg_strs r SnakeToCamelrZgs.  s!34 rc ^[U[5(a9UVs/sH+n[U[[45(a [U5OUPM- sn$UR 5VVs0sH7up#[ U5[U[[45(a [U5OU_M9 snn$s snfs snnf)zQReccursive method to convert all nested snake case dictionary keys to camel case.) isinstancelistdictSnakeToCamelDictr2rZ)arg_typelist_valr,r-s rr_r_os$ !  !H ht - - "  !  !(  )*#3%/d|%D%D 5 !%P)      s 2B$">B)c[5nUHnSU;a%[R"SRU55eUR SS5n[ U5S:d2[ USR 55S:Xd[ US5S:Xa%[R"SRU55eUSXS'M U$)zxReturns Dataplex task execution spec args as a map of key,value pairs from an input list of strings of format key=value.=zCExecution spec argument '{}' should be of the type argKey=argValue.rzEExecution spec argument '{}' should be of the format argKey=argValue.)r^argparseArgumentTypeErrorr#rXlenstrip)args_map_as_listexecution_args_map arg_entryarg_entry_splits rFetchExecutionSpecArgsrnsv#i )  & & O 6)   ooc1-O Oq q!'') *a / q! "a '  & & $fY/ .=Q-?q)*!$" r)ii)N)__doc__ __future__rrrrfr?googlecloudsdk.api_lib.storagerrgooglecloudsdk.api_lib.utilrr googlecloudsdk.callioper googlecloudsdk.corer r rrr)r6r>rZr_rnrrrrus\,&' 67,..)$22 <@&  <"r