
                         8    d Z ddlmZ ddlmZ ddlmZ d Zd Zy)z#Module for Managed Kafka arguments.    )concepts)	yaml_data)concept_parsersc                     t         j                  j                  d      }t        j                  j                  dt        j                  j                  |j                         d      dd      j                  |        y)z5Sets up an argument for the schema registry resource.zmanaged_kafka.schema_registryschema_registryTis_positionalzThe schema registry resource.)requiredNr   ResourceYAMLDataFromPathr   ConceptParserForResourcer   ResourceSpecFromYamlGetDataAddToParser)parserschema_registry_datas     9lib/googlecloudsdk/command_lib/managed_kafka/arguments.pyAddSchemaRegistryArgToParserr      su    "33<<% ++$$

&
&
( %  & ,  K    c                    t         j                  j                  d      }t        j                  j                  dt        j                  j                  |j                         d      ddddi      j                  |        y	)
z-Sets up an argument for the subject resource.zmanaged_kafka.subjectsubjectTr   zThe subject resource.zschema-registryz
--registry)r
   flag_name_overridesNr   )r   subject_datas     r   AddSubjectArgToParserr   %   sx    ++445LM,++$$



  %  ,l; ,  Kr   N)	__doc__ googlecloudsdk.calliope.conceptsr   $googlecloudsdk.command_lib.util.apisr   (googlecloudsdk.command_lib.util.conceptsr   r   r    r   r   <module>r#      s    * 5 : Dr   