Ë
    Ìi  ã                   ój   — d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dl	m
Z
 d dlmZ  G d„ d	e
«      Zy)
é    N)Ú	RunStatus)Ú	RunResult)ÚManifest)ÚLogNodeNoOpResult)Ú
BaseRunner)Ú
fire_eventc                   óD   — e Zd Zedefd„«       Zd	d„Zdefd„Zd	d„Z	d„ Z
y)
Ú
NoOpRunnerÚreturnc                 ó   — t        d«      ‚)Nzdescription not implemented)ÚNotImplementedError©Úselfs    úY/var/www/html/strategist-ai/venv/lib/python3.12/site-packages/dbt/runners/no_op_runner.pyÚdescriptionzNoOpRunner.description   s   € ä!Ð"?Ó@Ð@ó    Nc                  ó   — y ©N© r   s    r   Úbefore_executezNoOpRunner.before_execute   s   € Ør   Úmanifestc                 ó   — | j                   S r   )Únode)r   r   s     r   ÚcompilezNoOpRunner.compile   s   € Ø�y‰yÐr   c                 ó˜   — t        t        | j                  | j                  | j                  | j
                  j                  ¬«      «       y )N)r   ÚindexÚtotalÚ	node_info)r   r   r   Ú
node_indexÚ	num_nodesr   r   )r   Úresults     r   Úafter_executezNoOpRunner.after_execute   s6   € ÜÜØ ×,Ñ,Ø—o‘oØ—n‘nØŸ)™)×-Ñ-ô	õ	
r   c                 ó€   — t        |t        j                  g t        j                  «       j
                  ddi dd d ¬«
      S )Nr   zNO-OP)
r   ÚstatusÚtimingÚ	thread_idÚexecution_timeÚmessageÚadapter_responseÚfailuresÚbatch_resultsÚagate_table)r   r   ÚNoOpÚ	threadingÚcurrent_threadÚname)r   Úcompiled_noder   s      r   ÚexecutezNoOpRunner.execute    s@   € äØÜ—>‘>ØÜ×.Ñ.Ó0×5Ñ5ØØØØØØô
ð 	
r   )r   N)Ú__name__Ú
__module__Ú__qualname__ÚpropertyÚstrr   r   r   r   r"   r2   r   r   r   r
   r
      s9   „ ØðA˜Sò Aó ðAóð ó ó
ó
r   r
   )r.   Údbt.artifacts.schemas.resultsr   Údbt.artifacts.schemas.runr   Údbt.contracts.graph.manifestr   Údbt.events.typesr   Údbt.task.baser   Údbt_common.events.functionsr   r
   r   r   r   ú<module>r>      s&   ðÛ å 3Ý /Ý 1Ý .Ý $Ý 2ô"
�õ "
r   