def trace_node(debug=False):                                                                                                                                                                                                                                                                                                                                                                 
     def decorator(func):                                                                                                                                                                                                                                                                                                                                                                     
         if not debug:                                                                                                                                                                                                                                                                                                                                                                        
             # Return original function if debug is disabled                                                                                                                                                                                                                                                                                                                                  
             return func                                                                                                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                                                                                                                              
         def wrapper(node, *args, **kwargs):                                                                                                                                                                                                                                                                                                                                                  
             # Initialize trace if not exists                                                                                                                                                                                                                                                                                                                                                 
             if not hasattr(node, '_trace'):                                                                                                                                                                                                                                                                                                                                                  
                 node._trace = []                                                                                                                                                                                                                                                                                                                                                             
                                                                                                                                                                                                                                                                                                                                                                                              
             # Create trace entry                                                                                                                                                                                                                                                                                                                                                             
             trace_entry = {                                                                                                                                                                                                                                                                                                                                                                  
                 'timestamp': time.time(),                                                                                                                                                                                                                                                                                                                                                    
                 'node': node.name,                                                                                                                                                                                                                                                                                                                                                           
                 'action': func.__name__,                                                                                                                                                                                                                                                                                                                                                     
                 'args': args,                                                                                                                                                                                                                                                                                                                                                                
                 'kwargs': kwargs,                                                                                                                                                                                                                                                                                                                                                            
                 'status': 'started'                                                                                                                                                                                                                                                                                                                                                          
             }                                                                                                                                                                                                                                                                                                                                                                                
                                                                                                                                                                                                                                                                                                                                                                                              
             # Add initial entry                                                                                                                                                                                                                                                                                                                                                              
             node._trace.append(trace_entry)                                                                                                                                                                                                                                                                                                                                                  
                                                                                                                                                                                                                                                                                                                                                                                              
             try:                                                                                                                                                                                                                                                                                                                                                                             
                 # Execute the original method                                                                                                                                                                                                                                                                                                                                                
                 result = func(node, *args, **kwargs)                                                                                                                                                                                                                                                                                                                                         
                                                                                                                                                                                                                                                                                                                                                                                              
                 # Update entry with success status                                                                                                                                                                                                                                                                                                                                           
                 trace_entry.update({                                                                                                                                                                                                                                                                                                                                                         
                     'status': 'success',                                                                                                                                                                                                                                                                                                                                                     
                     'duration': time.time() - trace_entry['timestamp'],                                                                                                                                                                                                                                                                                                                      
                     'result': result                                                                                                                                                                                                                                                                                                                                                         
                 })                                                                                                                                                                                                                                                                                                                                                                           
                 return result                                                                                                                                                                                                                                                                                                                                                                
                                                                                                                                                                                                                                                                                                                                                                                              
             except Exception as e:                                                                                                                                                                                                                                                                                                                                                           
                 # Update entry with error status                                                                                                                                                                                                                                                                                                                                             
                 trace_entry.update({                                                                                                                                                                                                                                                                                                                                                         
                     'status': 'error',                                                                                                                                                                                                                                                                                                                                                       
                     'duration': time.time() - trace_entry['timestamp'],                                                                                                                                                                                                                                                                                                                      
                     'exception': str(e),                                                                                                                                                                                                                                                                                                                                                     
                     'traceback': traceback.format_exc()                                                                                                                                                                                                                                                                                                                                      
                 })                                                                                                                                                                                                                                                                                                                                                                           
                 raise                                                                                                                                                                                                                                                                                                                                                                        
             finally:                                                                                                                                                                                                                                                                                                                                                                         
                 # Finalize entry                                                                                                                                                                                                                                                                                                                                                             
                 trace_entry['end_time'] = time.time()                                                                                                                                                                                                                                                                                                                                        
                                                                                                                                                                                                                                                                                                                                                                                              
         return wrapper                                                                                                                                                                                                                                                                                                                                                                       
     return decorator   
...
DEBUG = True  # Set this globally or via configuration                                                                                                                                                                                                                                                                                                                                       
                                                                                                                                                                                                                                                                                                                                                                                              
 class Node(BaseNode):                                                                                                                                                                                                                                                                                                                                                                        
     @trace_node(debug=DEBUG)                                                                                                                                                                                                                                                                                                                                                                 
     def prep(self, shared):  
...

 # Access tracing information                                                                                                                                                                                                                                                                                                                                                                 
 for node in flow.get_all_nodes():                                                                                                                                                                                                                                                                                                                                                            
     print(f"Node: {node.name}")                                                                                                                                                                                                                                                                                                                                                              
     for entry in node._trace:                                                                                                                                                                                                                                                                                                                                                                
         print(f"  {entry['action']}: {entry['status']} in {entry['duration']:.2f}s")