dZddlmZddlmZddlmZddlmZddlm Z ddl mZddl m Z ddl mZdd l mZdd l mZdd lmZGd d e j&Zy)z%Cloud Pub/Sub schemas commit command.)absolute_import)division)unicode_literals) exceptions)schemas)base)flags) resource_args)util)logc.eZdZdZddiZedZdZy)Commitz!Commit a Pub/Sub schema revision.EXAMPLESa% To commit a PROTOCOL_BUFFER schema revision called "key-schema" that requires exactly one-string field named "key", run: $ {command} key-schema --definition="syntax = 'proto3'; message Message { optional string key = 1; }" --type=protocol-buffer To commit an equivalent AVRO schema revision, run: $ {command} key-schema --definition="{ 'type': 'record', 'namespace': 'my.ns', 'name': 'KeyMsg', 'fields': [ { 'name': 'key', 'type': 'string' } ] }" --type=avro cZtj|dtj|y)Nz to revise.)r AddSchemaResourceArgr AddCommitSchemaFlags)parsers $lib/surface/pubsub/schemas/commit.pyArgsz Commit.Args/s"&&v|< v&ctj}tj|j}|j r |j }n |j } |j|||j}tj|j$d|S#tj$r^}tj|}tj|dtj|j j"Yd}~yd}~wwxYw)aThis is what gets called when the user runs this command. Args: args: an argparse namespace. All the arguments that were provided to this command invocation. Returns: A serialized object (dict) describing the results of the operation. This description fits the Resource described in the ResourceRegistry under 'pubsub.projects.schemas'. Raises: util.RequestFailedError: if any of the requests to the API failed. ) schema_refschema_definition schema_typezschema revision)kindfailedN)r)r SchemasClientr ParseSchemaNameschemadefinition_file definitionrtypeapi_ex HttpErrorr HttpExceptionr CreatedResourceCreateFailureErrorMessagepayloadstatus_messagename)selfargsclientrr!resulterrorexcs rRunz Commit.Run5s " " $F%%dkk2J ''j??j  }}&iif *;< M     $ $U +c   // 0J0JK   sBD .ADD N)__name__ __module__ __qualname____doc__ detailed_help staticmethodrr1rrrr s/) -'' &rrN)r5 __future__rrrapitools.base.pyrr#googlecloudsdk.api_lib.pubsubrgooglecloudsdk.api_lib.utilgooglecloudsdk.callioper!googlecloudsdk.command_lib.pubsubr r r googlecloudsdk.corer Commandrr8rrrAs;,&'112(3;2#;T\\;r