3 jSrSSKJr SSKJr SSKJr SSKrSSKJr SSKJr SSK J r S r S r S r g) z%Utility functions for task execution.)absolute_import)division)unicode_literalsN)errors)optimize_parameters_util) propertiescNUHnXRLdMURs $ g)zFGets first item with matching topic from list of task output messages.N)topicpayload)messagesr messages 9lib/googlecloudsdk/command_lib/storage/tasks/task_util.py"get_first_matching_message_payloadrs%g  __ c[RRRR 5n[RRR R 5nUbUc[ R$US:=(d US:$)a"Checks execution settings to determine if parallelism should be used. This function is called in some tasks to determine how they are being executed, and should include as many of the relevant conditions as possible. Returns: True if parallel execution should be used, False otherwise. )rVALUESstorage process_countGetInt thread_countrDEFAULT_TO_PARALLELISM)rrs rshould_use_parallelismr$sr##++99@@B-""**77>>@,l2 $ : ::   .lQ..rc[RRS:d<[RRS:Xa[RRS:ao[R "SR [RR[RR[RR55egg)zwTask execution assumes Python versions >=3.5. Raises: InvalidPythonVersionError: if the Python version is not 3.5+. z]This functionality does not support Python {}.{}.{}. Please upgrade to Python 3.5 or greater.N)sys version_infomajorminorrInvalidPythonVersionErrorformatmicrorrrequire_python_3_5r%7s  aC$4$4$:$:a$?$'$4$4$:$:Q$>  * * $$*F    " "    " "    " "%   %?%@r)__doc__ __future__rrrr"googlecloudsdk.command_lib.storagerrgooglecloudsdk.corerrrr%r$rrr*s.,&' 5G*/& r