"SrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSKJ r SSK r "SS\R5r \R"S S S /5r\R"S S S/5r"SS\ R "\R"\55rg)azAbstract operation class that command operations will inherit from. Should typically be executed in a task iterator through googlecloudsdk.command_lib.storage.tasks.task_executor. Manual execution example: >>> class CopyTask(Task): ... def __init__(self, src, dest): ... ... >>> my_copy_task = new CopyTask('~/Desktop/memes.jpg', '/kernel/') >>> my_copy_task.Execute() )absolute_import)division)unicode_literalsN) debug_outputc<\rSrSrSrSrSrSrSrSr Sr S r S r S r S rg )Topic+z$Categorizes different task messages.api_download_resultchange_exit_codecrc32ccreated_resourceerror fatal_errormd5set_iam_policyuploaded_componentN)__name__ __module__ __qualname____firstlineno____doc__API_DOWNLOAD_RESULTCHANGE_EXIT_CODECRC32CCREATED_RESOURCEERROR FATAL_ERRORMD5SET_IAM_POLICYUPLOADED_COMPONENT__static_attributes__r4lib/googlecloudsdk/command_lib/storage/tasks/task.pyrr+s8,-' &' %+ ##.+r#rMessagetopicpayloadOutputadditional_task_iteratorsmessagescV\rSrSrSrSr\RS Sj5rS Sjr Sr Sr g) Task`a)Abstract class to represent one command operation. Attributes: change_exit_code (bool): If True, failure of this task should update the exit_code to 1. Defaults to True. parallel_processing_key (Optional[Hashable]): Identifies a task during execution. If this value is not None, the executor will skip this task if another task being executed is using the same key. If this value is None, the executor will not skip any tasks based on it. received_messages (Iterable[Message]): Messages sent to this task by its dependencies. c.SUlSUl/Ulg)NTr parallel_processing_keyreceived_messagesselfs r$__init__ Task.__init__ns D#'D Dr#Ncg)zPerforms some work based on class attributes. Args: task_status_queue (multiprocessing.Queue): Used by task to report it progress to a central location. Returns: An Output instance, or None. Nr)r3task_status_queues r$execute Task.executess r#cAAg)axTask executor calls this method on a completed task before discarding it. An example use case is a subclass that needs to report its final status and if it failed or succeeded at some operation. Args: error (Exception|None): Task executor may pass an error object. task_status_queue (multiprocessing.Queue): Used by task to report it progress to a central location. Nr)r3rr7s r$ exit_handlerTask.exit_handlers   r#c.[R"U5$N)r generic_reprr2s r$__repr__ Task.__repr__s  $ $T **r#r/r>)NN) rrrrrr4abcabstractmethodr8r;r@r"rr#r$r,r,`s0        +r#r,)r __future__rrrrB collectionsenumgooglecloudsdk.core.utilrsixEnumr namedtupler%r(with_metaclassABCMetaobjectr,rr#r$rNs ''  1  ,DII ,*    i 4     *-  /+3  ckk6 2/+r#