code: def run_failure_step_group(pipeline, context):
      
      logger.debug("starting")
      try:
          assert pipeline
          # if no on_failure exists, it'll do nothing.
          run_step_group(pipeline_definition=pipeline,
                         step_group_name='on_failure',
                         context=context)
      except Exception as exception:
          logger.error("Failure handler also failed. Swallowing.")
          logger.error(exception)
  
      logger.debug("done")
docs: Run the on_failure step group if it exists.
  
      This function will swallow all errors, to prevent obfuscating the error
      condition that got it here to begin with.