SrSSKJr SSKJr SSKJr SSKrSSKJr SSKJ r SSK r Sr S r S r S rSS jrS rSrSrg)z.Utilities for interacting with streaming logs.)absolute_import)division)unicode_literalsN)encoding)streamzTvalue(severity,timestamp.date("%Y-%m-%d %H:%M:%S %z",tz="LOCAL"), task_name,message) cz[R"[XS9U[US9n[ UR 5U5$)aReturns the streaming log of the job by id. Args: name: string id of the entity. continue_function: One-arg function that takes in the number of empty polls and outputs a boolean to decide if we should keep polling or not. If not given, keep polling indefinitely. polling_interval: amount of time to sleep between each poll. task_name: String name of task. allow_multiline: Tells us if logs with multiline messages are okay or not. ) task_name)filterspolling_intervalcontinue_interval continue_func)r LogFetcher _LogFilters_CONTINUE_INTERVAL_SplitMultiline YieldLogs)namecontinue_functionr r allow_multiline log_fetchers -lib/googlecloudsdk/command_lib/ai/log_util.py StreamLogsr$s=!!$4'*% '+ ..0/ BBczSSRU5/nU(a URSRU55 U$)zReturns filters for log fetcher to use. Args: name: string id of the entity. task_name: String name of task. Returns: A list of filters to be passed to the logging API. zresource.type="ml_job"zresource.labels.job_id="{0}"zresource.labels.task_name="{0}")formatappend)rr r s rrr9s> > E Ed K ' NN4;;IFG .rc## UH_n[U5nUSR5nU(aUv M.U(dS/nUH!n[R"U5nXVS'Uv M# Ma g7f)zSplits the dict output of logs into multiple lines. Args: log_generator: iterator that returns a an ml log in dict format. allow_multiline: Tells us if logs with multiline messages are okay or not. Yields: Single-line ml log dictionaries. messageN) _EntryToDict splitlinescopydeepcopy) log_generatorrloglog_dictmessagesrsingle_line_logs rrrKsfcC H "--/H n 4'--1%, "sA'A)c0nUR(aURROSUS'URUS'[U5US'/nURb:[ UR5nSU;aUS(aUR US5 OrHsM5&' %2  C*$0*5+r