li UddlZddlZddlmZmZmZmZdZdZiZ ee ejfe d<de dee effdZ dee effd Zd Zde ddfd Zd edee ej"ffd Zd edee ej"ffdZde d edee ej"ffdZde d ej"ddfdZde de ddfdZej.d ededfdZej.d ededfdZy)N)Any GeneratorMappingDictlog_task_ _context_varsprefixreturnci}tj}t|}|D]?}|jj |s||t us+||||j|d<A|SN) contextvars copy_contextlenname startswithEllipsis)r rvctx prefix_lenks b/var/www/html/strategist-ai/venv_dbt/lib/python3.12/site-packages/dbt_common/events/contextvars.pyget_contextvarsr sj B  " " $CVJ - 66  V $Qx)?&)!fBqvvjk" #- Ic6tt}d|vr|dSiS)N node_info)r LOG_PREFIXcvarss r get_node_infor s$ J 'Ee[!! rc4tt}d|vr|dSy)N project_root)r TASK_PREFIXrs rget_project_rootr$!s" K (E^$$rctj}|D]3}|jj|s|j t 5yr )rrrrsetr)r rrs rclear_contextvarsr')s<  " " $C  66  V $ EE(Orkwargsc "ttfi|Sr )set_contextvarsrr(s rset_log_contextvarsr,0s : 0 00rc "ttfi|Sr )r*r#r+s rset_task_contextvarsr.4s ; 1& 11rc i}|jD])\}}||} t|}|j |||<+|S#t$r'tj|t }|t|<YGwxYw)N)default)itemsr KeyErrorr ContextVarrr&)r r( cvar_tokensrv prefix_keyvars rr*r*:sK $1xs^  , +C  A$   ,((XFC(+M* % ,s A-A10A1c t|jD]%\}}||}t|}|j|'yr )r1r reset)r r(rr5r6r7s rreset_contextvarsr:Js= 1xs^ J' ! rkeysch|D]-}||}|tvst|jt/yr )r r&r)r r;rr6s runset_contextvarsr=Rs9 4xs^  & * % ) )( 34r)NNNc+Ktt}|j|jzDcic]}||| }}ttfi| dt tg|jttfi|ycc}w#t tg|jttfi|wxYwwr )rrr;r*r=r(contextrsaveds rlog_contextvarsrBZsj)G$+LLNV[[]$B CqQ ] CE CJ)&)- *5v{{}5 ,e, D *5v{{}5 ,e,(3C BCB 4C 0B==Cc+Ktt}|j|jzDcic]}||| }}ttfi| dt tg|jttfi|ycc}w#t tg|jttfi|wxYwwr )rr#r;r*r=r?s rtask_contextvarsrEhsk*G$+LLNV[[]$B CqQ ] CE CK*6*. +6 6 -u- D +6 6 -u-rC) contextlibrtypingrrrrrr#r strr3__annotations__rr r$r'Tokenr,r.r*r:r=contextmanagerrBrErrrMs00  35 tC///05 C DcN tCH~cd1#1'#{7H7H2H*I123273 8I8I3I+J2 C 3 73 @Q@Q;Q3R  c[->->44c4#4$4  -c -i0@&A - -  .s .y1A'B . .r