+
    5mj@	  c            	         ^ RI Ht ^ RIt^ RIHu Ht ^ RIt	^ RI
t
^ RIHt ]! ]4      P                  4       P                  ^,          R,          t]	P"                  P%                  R]4      t]	P"                  P)                  ]4      t]P,                  tRt]]Jt]'       g   ]P4                  ! R]3R]]34      RR]P6                  ! 4       9   g   ]P8                  ! ]4      '       d   ]P:                  ! ]4      MRR]P:                  ! ]4      R	]P:                  ! ]4      /,          tR
R]/,          t] ! ]PB                  ! ]4      4      hR;t;tt]P,                  PE                  ]4       R t#R t$R t%R# )    )annotationsN)Pathzk3s_job_runner.pyk3s_job_runnerpy0specpy2py5zassert %(py7)spy7c                h  aa \        R RR/RRRRRR/ //.//R RR/RRRRRRR	^///.//.4      oV P                  \        R
V3R l4       . oV3R lpV P                  \        P                  RV4       \        P                  pRpRpRp^qb! W4WV4      p^qV8H  q'       Eg=   \
        P                  ! R V	3R!Wx34      RR\        P                  ! 4       9   g!   \
        P                  ! \        4      '       d   \
        P                  ! \        4      MRR\
        P                  ! V4      R\
        P                  ! V4      R\
        P                  ! V4      R\
        P                  ! V4      R\
        P                  ! V4      R\
        P                  ! V4      R\
        P                  ! V4      /,          p
RRV
/,          p\        \
        P                  ! V4      4      hR;p;p;p;p;p;p;r. R"O.pSV8H  q"'       g   \
        P                  ! R V3R#SV34      RR\        P                  ! 4       9   g   \
        P                  ! S4      '       d   \
        P                  ! S4      MRR\
        P                  ! V4      /,          pRRV/,          p\        \
        P                  ! V4      4      hR;r,R# )$metadatanamecdx-podstatuscontainerStatusesagentstaterunning
terminatedexitCodeget_podc                    < \        S4      # Nnextargspodss   *c/home/user/overdeck-private-tests/workstation-ai-broad/modules/systray/tests/test_k3s_job_runner.py<lambda>Jtest_runner_streams_agent_logs_and_returns_its_exit_code.<locals>.<lambda>   	    d    c                T   < SP                  V 4       \        P                  ! V ^ 4      # )r   )append
subprocessCompletedProcess)argvkwargscommandss   &,r   fake_runJtest_runner_streams_agent_logs_and_returns_its_exit_code.<locals>.fake_run   s"    **433r!   runoverdeckNcdx-jobr   r   r   py4py6py8py10py12py15assert %(py17)spy17r(   py3zassert %(py5)sr   ==zh%(py12)s
{%(py12)s = %(py2)s
{%(py2)s = %(py0)s.run
}(%(py4)s, %(py6)s, %(py8)s, %(py10)s)
} == %(py15)s)kubectlz--namespacer,   logsz-fr   z-cr   )z%(py0)s == %(py3)s)itersetattrr   r$   r+   
@pytest_ar_call_reprcompare@py_builtinslocals_should_repr_global_name	_safereprAssertionError_format_explanation)monkeypatchr)   @py_assert1@py_assert3@py_assert5@py_assert7@py_assert9@py_assert11@py_assert14@py_assert13@py_format16@py_format18@py_assert2@py_format4@py_format6r(   r   s   &              @@r   8test_runner_streams_agent_logs_and_returns_its_exit_coderT      s0   	fi((5HWg	27K
 5 	 
fi((5HWgz26F'GHK
 5 		 D 	3KLH4 115(CDjD$D	D2Dj	>D"D"DDDDD>DDDDDD>DDDD>DDDDDDjDDD$DDD	DDD2DDD>DDD"DDDDDDDDD  8     8      8   8           r!   c                  a \        R RR/RRRRRR/ //.//R RR/RRRRRRR	^ ///.//.4      oV P                  \        R
V3R l4       V P                  \        P                  RR 4       \        P                  pRpRpRp^qb! W4WV4      p^ qV8H  q'       Eg=   \
        P                  ! R%V	3R&Wx34      RR\        P                  ! 4       9   g!   \
        P                  ! \        4      '       d   \
        P                  ! \        4      MRR\
        P                  ! V4      R\
        P                  ! V4      R\
        P                  ! V4      R\
        P                  ! V4      R\
        P                  ! V4      R\
        P                  ! V4      R\
        P                  ! V4      /,          p
RRV
/,          p\        \
        P                  ! V4      4      hR;p;p;p;p;p;p;rRqP                  q! 4       qP                  qV9   pV'       g   \
        P                  ! R'V3R(W34      R\
        P                  ! V4      RR\        P                  ! 4       9   g   \
        P                  ! V4      '       d   \
        P                  ! V4      MRR \
        P                  ! V4      R!\
        P                  ! V4      R"\
        P                  ! V4      /,          pR#R$V/,          p\        \
        P                  ! V4      4      hR;p;p;p;rR# ))r   r   r   r   r   r   r   r   r   r   r   c                    < \        S4      # r   r   r   s   *r   r   Rtest_log_stream_failure_keeps_supervising_until_agent_terminates.<locals>.<lambda>/   r    r!   r+   c                0    \         P                  ! V ^4      # )   )r$   r%   )r&   r'   s   &,r   r   rW   3   s    z::4Cr!   r,   Nr-   r   r   r   r.   r/   r0   r1   r2   r3   r4   r5   zlog stream detachedpy1r6   capsysr   r	   py9zassert %(py11)spy11r7   r9   )in)zb%(py1)s in %(py9)s
{%(py9)s = %(py7)s
{%(py7)s = %(py5)s
{%(py5)s = %(py3)s.readouterr
}()
}.err
})r<   r=   r   r$   r+   r>   r?   r@   rA   rB   rC   rD   rE   
readouterrerr)rF   r[   rG   rH   rI   rJ   rK   rL   rM   rN   rO   rP   @py_assert0@py_assert4@py_assert6@py_assert8rQ   @py_format10@py_format12r   s   &&                 @r   @test_log_stream_failure_keeps_supervising_until_agent_terminatesrg   &   s    	fi((5HWg	27K
 5 	 
fi((5HWgz1o'FGK
 5 		 D 	3KL!!C CjC$C	C2Cj	>C!C!CCCCC>CCCCCC>CCCC>CCCCCCjCCC$CCC	CCC2CCC>CCC!CCCCCCCCC ;$5$5;$5$7;$;$;;$;;;;;; ;;; ;;;;;;F;;;;F;;;$5;;;$7;;;$;;;;;;;;;;r!   c                   R RRRRRRR///.//p\         P                  q"! V4      pRqCV8H  qU'       Eg3   \        P                  ! RV3RW434      R	R
\        P
                  ! 4       9   g!   \        P                  ! \         4      '       d   \        P                  ! \         4      MR
R\        P                  ! V4      RR\        P
                  ! 4       9   g   \        P                  ! V4      '       d   \        P                  ! V4      MRR\        P                  ! V4      R\        P                  ! V4      /,          pRRV/,          p\        \        P                  ! V4      4      hR;p;p;rT\         P                  q"! V4      pRqCV8H  qU'       Eg3   \        P                  ! RV3RW434      R	R
\        P
                  ! 4       9   g!   \        P                  ! \         4      '       d   \        P                  ! \         4      MR
R\        P                  ! V4      RR\        P
                  ! 4       9   g   \        P                  ! V4      '       d   \        P                  ! V4      MRR\        P                  ! V4      R\        P                  ! V4      /,          pRRV/,          p\        \        P                  ! V4      4      hR;p;p;rTR# )r   r   r   r   r   waitingreasonImagePullBackOffzagent: ImagePullBackOffr   r   r   r6   podr   r0   zassert %(py10)sr1   Nr7   )zU%(py5)s
{%(py5)s = %(py2)s
{%(py2)s = %(py0)s.startup_failure
}(%(py3)s)
} == %(py8)s)ri   N)zR%(py5)s
{%(py5)s = %(py2)s
{%(py2)s = %(py0)s.agent_status
}(%(py3)s)
} == %(py8)s)r   startup_failurer>   r?   r@   rA   rB   rC   rD   rE   agent_status)rF   rl   rG   rb   rJ   rc   @py_format9@py_format11s   &       r   *test_fatal_waiting_state_fails_immediatelyrq   :   s   )VWg	$T H - ,	 
 C ))K)#.K2KK2KKKKKK.KKKKKK>KKKK>KKK)KKKKKK#KKKK#KKK.KKK2KKKKKKKKK&&@&s+@/@@/@@@@@@+@@@@@@>@@@@>@@@&@@@@@@s@@@@s@@@+@@@/@@@@@@@@@r!   )is not)z2%(py2)s
{%(py2)s = %(py0)s.loader
} is not %(py5)s)&
__future__r   builtinsr@   _pytest.assertion.rewrite	assertionrewriter>   importlib.util	importlibr$   pathlibr   __file__resolveparentsMODULEutilspec_from_file_locationr   module_from_specr   loaderrG   rb   rH   r?   rA   rB   rC   rS   @py_format8rD   rE   exec_modulerT   rg   rq    r!   r   <module>r      s    "       
h			!	)	)!	,/B	B~~--.>G006{{ $ {$    {$     t   t   {   $           '.<(Ar!   