code: def clean_cache_upstream(self):
          
          logger.info('Cleaning cache for the entire upstream pipeline')
          for step in self.all_upstream_steps.values():
              logger.info('Step {}, cleaning cache'.format(step.name))
              step.output = None
          return self
docs: Clean cache for all steps that are upstream to `self`.