def METHOD_NAME(self, pipeline_args: JobVariant):
    # all steps depend from us and may consume our output
    for step in pipeline_args.steps():
        step._notifications_cfg = self.trait.notifications_cfg(step.notifications_cfg_name())