SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SS K J r SS K J r SS K Jr SS K Jr SSjrSSjrg )z?Function for executing the tasks contained in a Task Iterator. )absolute_import)division)unicode_literals)errors)optimize_parameters_util)plurality_checkable_iterator)task_graph_executor) task_status) task_util)log) propertiesNc Sn/nUHnUbXlSnURUS9nURXr5 UcM5URbURUR5 URcMl/n URHn [U U UUS9up[X5nM M XE4$![axn U n[U[R 5(dQU(aJ[ R"[U 55 UR(aSnSn A URXr5 GMeSn A ff=f!URXr5 f=f)aWExecutes task objects sequentially. Args: task_iterator (Iterable[task.Task]): An iterator for task objects. received_messages (Iterable[task.Message]): Messages sent to each task in task_iterator. task_status_queue (multiprocessing.Queue|None): Used by task to report it progress to a central location. continue_on_error (bool): If True, execution will continue even if errors occur. Returns: Tuple[int, Iterable[task.Message]]: The first element in the tuple is the exit code and the second element is an iterable of messages emitted by the tasks in task_iterator. rN)task_status_queuercontinue_on_error)received_messagesexecute Exception isinstancer FatalErrorr errorstrchange_exit_code exit_handlermessagesextendadditional_task_iterators_execute_tasks_sequentialmax) task_iteratorrrr exit_code#messages_from_current_task_iteratortasktask_execution_error task_outputemessages_for_dependent_tasksadditional_task_iteratorexit_code_from_dependent_taskss =lib/googlecloudsdk/command_lib/storage/tasks/task_executor.pyrr!sO()(*%d$0ALL3DLEk ,@')001E1EF,,8%'"&1&K&K " %(,"3"3  5 E& 6B 'L=N  77A  -v/@/@AA #a&  ) ,@   ,@s0B(( D*2AD% D-$D%%D**D--Ecn[R"5 [R"U5n[R "UR 5S9 U(a[R"5(a[R"U[RRRR5[RRRR5UUS9R!5nU$["R$"X#5 ['UUUS9upgSSS5 U$!,(df  W$=f)a\Call appropriate executor. Args: task_iterator: An iterator for task objects. parallelizable (boolean): Should tasks be executed in parallel. task_status_queue (multiprocessing.Queue|None): Used by task to report its progress to a central location. progress_manager_args (task_status.ProgressManagerArgs|None): Determines what type of progress indicator to display. continue_on_error (bool): Only applicable for sequential mode. If True, execution will continue even if errors occur. Returns: An integer indicating the exit_code. Zero indicates no fatal errors were raised. ) is_estimated_multi_file_workload)max_process_count thread_countrprogress_manager_argsrN)r require_python_3_5rPluralityCheckableIteratorrdetect_and_set_best_config is_pluralshould_use_parallelismr TaskGraphExecutorr VALUESstorage process_countGetIntr/runr progress_managerr)r!parallelizablerr0r!plurality_checkable_task_iteratorr"_s r+ execute_tasksr@as*  "==mL$55 + 5 5 7: 88::#55)$++33AAHHJ&&..;;BBD+3 5 69SU    % %&7 O. +--/li P  P O s D%% D4)NNF)FNNF)__doc__ __future__rrr"googlecloudsdk.command_lib.storagerrr(googlecloudsdk.command_lib.storage.tasksr r r googlecloudsdk.corer r rr@r+rHsQ ''5GKH@>#*150405=8B"'$((,$) ,rG