code: def _decorate_source(source):
      for message in source:
          yield ((message.dt, message.source_id), message)
  
label_desc: Use image node_id 1 for calling a global function with example usage: _decorate_source(source) without return types