JSrSSKrSSKJr SSKJr SSKJr SSK J r \R"5r S\S\4S jrS \S\ R R"4S jrS \S\ R&R"4S jrS \\4SjrSrSrg)z(Utilities for Dataplex Entries commands.N)List)util)messages) arg_parsers datetime_strreturnc\[RRU5R5$)zWParses datetime string, validates it and outputs the new datetime string in ISO format.)rDatetimeParse isoformat)rs 2lib/googlecloudsdk/command_lib/dataplex/parsers.py IsoDateTimers"    # #L 1 ; ; == aspects_filec [R"5nU"U5n[U[5(d[R"SUS35e/nUR 5H_upEUR [RRRU[R"U[R5S95 Ma [RRUS9$)aParse aspects from a YAML or JSON file. Perform a basic validation that aspects are provided in a correct format. Args: aspects_file: The path to the YAML/JSON file containing aspects. Returns: A list of aspects parsed to a proto message (AspectsValue). Invalid aspects file: z. It must contain a map with a key in the format `ASPECT_TYPE@PATH` (or just `ASPECT_TYPE` if attached to the root path). Values in the map represent Aspect's content, which must conform to a template defined for a given `ASPECT_TYPE`.keyvalueadditionalProperties)rYAMLFileContents isinstancedictArgumentTypeErroritemsappenddataplex_messageGoogleCloudDataplexV1Entry AspectsValueAdditionalProperty messages_utilDictToMessageWithErrorCheckGoogleCloudDataplexV1Aspectrparser raw_aspectsaspects aspect_keyaspects r ParseAspectsr+!s  ' ' )&|$+ K & &  ' ' /   ''--/j NN33@@SS;;(DD T 0  4 4 A A" B rc [R"5nU"U5n[U[5(d[R"SUS35e/nUR 5HupESU;a[R"SUS35eUR [RRRU[R"U[R5S95 M [RRUS9$)aEParse aspects from a YAML or JSON file for EntryLinks. Perform a basic validation that aspects are provided in a correct format. Aspect keys for EntryLinks cannot contain paths. Args: aspects_file: The path to the YAML/JSON file containing aspects. Returns: A list of aspects parsed to a proto message (AspectsValue). rz. It must contain a map with a key in the format `PROJECT_ID.LOCATION.ASPECT_TYPE_ID`. Values in the map represent Aspect's content, which must conform to a template defined for a given `PROJECT_ID.LOCATION.ASPECT_TYPE_ID`.@z Aspect key "z" is invalid for an EntryLink. Aspect keys for EntryLinks must be in PROJECT_ID.LOCATION.ASPECT_TYPE_ID format and cannot contain a path.rr)rrrrrrrrGoogleCloudDataplexV1EntryLinkr r!r"r#r$r%s r ParseEntryLinkAspectsr/Is  ' ' )&|$+ K & &  ' ' /E E  ''--/j j  ) )  %( (   NN77DDWW;;(DD X 0  8 8 E E" F r ancestorsc8Uc/$[[SU55$)zParse ancestors from a string. Args: ancestors: A list of strings containing the JSON representation of the Ancestors. Returns: A list of ancestors parsed to a proto message (GoogleCloudDataplexV1EntrySourceAncestor). ct[R"[R"U5[R 5$)N)r"r#jsonloadsr(GoogleCloudDataplexV1EntrySourceAncestor)ancestors r +ParseEntrySourceAncestors..s$=DDjj"GG r)listmap)r0s r ParseEntrySourceAncestorsr;ws. I      rcUcg/nUHn[R"[R"[R "U55[ R5nUR(d[R"S5eUR[ RRRURUS95 M U$)zParse access groups from a list of JSON strings. Args: access_groups: A list of JSON strings representing Access Group(s). Returns: A list of AdditionalProperty objects. Nz%Access group must have an "id" field.r)r"r# dataplex_utilSnakeToCamelDictr3r4r+GoogleCloudDataplexV1DataProductAccessGroupidrrr GoogleCloudDataplexV1DataProductAccessGroupsValuer!) access_groupsr access_groupaccess_group_msgs r ParseAccessGroupsrFs  %#l$@@&&tzz,'?@DD     ) ) 1  LL99KK^^ ##+; _ $ ,rcUcg/nUHn[R"U5nURSS5nU(d[R"S5e[ R "[R"U5[R5nUR[RRRXES95 M U$)zParse access group configs from a list of JSON strings. Args: access_group_configs: A list of JSON strings representing Access Group Config(s). Returns: A list of AdditionalProperty objects. Nr@z,Access group config must have an "id" field.r)r3r4poprrr"r#r=r>r/GoogleCloudDataplexV1DataAssetAccessGroupConfigrGoogleCloudDataplexV1DataAssetAccessGroupConfigsValuer!)access_group_configsadditional_propertiesaccess_group_config config_dictgroup_idaccess_group_config_msgs r ParseAccessGroupConfigsrRs! 1**01KtT*H   ) ) 8 ,GG&&{3HH   77OObb c 2( r)__doc__r3typingrgooglecloudsdk.api_lib.dataplexrr=googlecloudsdk.api_lib.utilrr"googlecloudsdk.callioperGetMessageModulerstrrrr r+r.r/r;rFrRrr r[s/ AA/ 113>c>c> %%00==%P++44AA+\c0@"r