code: def register_function(cls, fn, label):
          
          if label in cls.registered_functions:
              log.warning("Overwriting existing registered function %s", label)
  
          fn.label = label
          cls.registered_functions[fn.label] = fn
docs: Register a function with the pipeline.