o Xiq!@sUdZddlmZddlZddlmZgdZddlZddlZddl Z ddl Z ddl m Z m Z ddlmZddlmZdad ed <ejd d Gd ddZdddZdddZGdddZdS)z)Journaling system for ONNX IR operations.) annotationsN)Any)Journal JournalEntryget_current_journal)CallableSequence)Self) _wrappersJournal | None_current_journalT)frozenc@sjeZdZUdZded<ded<ded<ded<d ed <d ed <d ed<ded<edddZdddZdS)raA single journal entry recording an operation on the IR. Attributes: timestamp: The time at which the operation was performed. operation: The name of the operation performed. class_: The class of the object on which the operation was performed. class_name: The name of the class of the object. ref: A weak reference to the object on which the operation was performed. To access the object, call ``ref()``. Note that ``ref`` may be ``None``, and ``ref()`` may return ``None`` if the object has been garbage-collected. obj: The referenced object, or None if it has been garbage-collected or not recorded. This is the same as calling ``entry.ref() if entry.ref is not None else None``. object_id: The unique identifier of the object (id()). stack_trace: The stack trace at the time of the operation. details: Additional details about the operation. float timestampstr operationtypeclass_ class_namezweakref.ref | Nonerefint object_idlist[traceback.FrameSummary] stack_trace str | Nonedetailsreturn Any | NonecCs|jdurdS|S)zTGet the referenced object, or None if it has been garbage-collected or not recorded.N)rselfr R/home/ubuntu/.local/lib/python3.10/site-packages/onnx_ir/journaling/_journaling.pyobj5s zJournalEntry.objNonec Cstj|jd}tdddtd|td|jtd|jd|jd |jd ur6d }n|}d urCt |}nd }td | dD] }td|qN|j rotd|j dD] }td|qe|j rd }t |j D]}|jdd}d|vsd|vr|}nqytd|d urtd|jd|jd|jd|jrtd|jdntdtd|j D]}td|jd|jd|jd|jrtd|jdqtdddd S)z:Display the journal entry in a detailed multi-line format.%Y-%m-%d %H:%M:%S.%fzzP================================================================================zTimestamp: zOperation: zClass: z (id=)N zObject: z zDetails:\/onnx_ironnx_ir/passeszUser Code Location:z : in z >>> z zFull Stack Trace:z )datetime fromtimestamprstrftimeprintrrrrreprsplitrrreversedfilenamereplacelinenonameline)rr object_reprr"r; user_framefr7r r r!display<sV   "zJournalEntry.displayN)rrrr#)__name__ __module__ __qualname____doc____annotations__propertyr"r?r r r r!rs  rrcCstS)z Get the current journal, if any.)r r r r r!rssrrcCstddS)N) traceback extract_stackr r r r!_get_stack_tracexsrJc@sfeZdZdZdddZd ddZdd d Zed!d d Zd"d#ddZ d$ddZ dddZ dddZ dS)%raA journaling system to record operations on the ONNX IR. It can be used as a context manager to automatically record operations within a block. Example:: from onnx_ir.journaling import Journal journal = Journal() with Journal() as journal: # Perform operations on the ONNX IR pass for entry in journal.entries: print(f"Operation: {entry.operation} on {entry.class_name}") You can also filter the entries by operation or class name using the `filter` method:: filtered_entries = [ entry for entry in journal.entries if entry.operation == "set_name" and entry.class_name == "Node" ] rr#cCsg|_d|_g|_i|_dSN)_entries_previous_journal_hooks_original_methodsrr r r!__init__s zJournal.__init__r cCst|_|at||_|SrK)r rMr wrap_ir_classesrOrr r r! __enter__s zJournal.__enter__cCst|j|jadSrK)r restore_ir_classesrOrMr )rexc_type exc_valueexc_tbr r r!__exit__s  zJournal.__exit__Sequence[JournalEntry]cCs|jS)z!Get all recorded journal entries.)rLrr r r!entriesszJournal.entriesNr"rrrrrc Cs^tt||j|jj|durt|ndt|t|d}|j ||j D]}||q&dS)zRecord a new journal entry.N)rrrrrrrr) rtime __class__rAweakrefridrJrLappendrN)rr"rrentryhookr r r!records  zJournal.recordr`Callable[[JournalEntry], None]cCs|j|dS)zHAdd a hook that will be called whenever a new journal entry is recorded.N)rNr^)rr`r r r!add_hookszJournal.add_hookcCs|jdS)zClear all hooks.N)rNclearrr r r! clear_hooksszJournal.clear_hooksc Cs||jD]}|jrd|jdnd}tj|jd}|jrPd}t|jD]}|j dd}d|vs6d |vr:|}nq%|durM|jd |j d |j }nd }nd }t t d |d|d|j durhd}n!| } durt|  dd}t|dkr|ddd}nd}| dd} t| dkr| ddd} t d|jd|jd|jd|d |rt d| dqdS)zDisplay all journal entries.z []r$Nr*r+r,r-r.r/z [z] r%r'r)z\nd_z[...]r(zClass: z(id=z). Operation: z . Object: .zDetails: )rLrr0r1rr2rr6r7r8r9r:r3rr4lenrrr) rr_rrframer>r7locationr<r" details_textr r r!r?sJ     "zJournal.displayr@)rr )rrXrK)r"rrrrrrr#)r`rbrr#) rArBrCrDrPrRrWrFrYrarcrer?r r r r!r|s       r)rr )rr)rD __future__rr\typingr__all__ dataclassesr0rZrHcollections.abcrrtyping_extensionsr onnx_ir.journalingr r rE dataclassrrrJrr r r r!s$       Y