docs: def delete_rpms(self, repo_name, rpms, env):
          """
          `repo_name` - Name of the repository rpms live in (includes -env)
          `rpms` - A list of rpm filenames to delete
          `env` - Environment we're currently deleting in
  
          Delete rpms from a repository in specified environments
          """
          for rpm in rpms:
              data = {
                  'criteria': {
                      'type_ids': ['rpm'],
                      'filters': {
                          'unit': {
                              'filename': {
                                  "$regex": rpm
                                  }
                              }
                          }
                      }
                  }
              _r = self.connectors[env].post("/repositories/%s/actions/unassociate/" % (repo_name), data)
              if _r.status_code != Constants.PULP_POST_ACCEPTED:
                  _r.raise_for_status()
              else:
                  unassociate_task = juicer.utils.load_json_str(_r.content)['task_id']
                  unassociate_poller = TaskPoller.TaskPoller(unassociate_task, self.connectors, env)
                  unassociate_poller.poll_until_finished()
                  juicer.utils.Log.log_info("Remove call for %s from %s was accepted" %
                                            (rpm, repo_name))
                  # unassociation was accepted so publish destination repo after deleting orphans
                  _r = self.connectors[env].delete('/content/orphans/rpm/')
                  delete_task = juicer.utils.load_json_str(_r.content)['task_id']
                  delete_poller = TaskPoller.TaskPoller(delete_task, self.connectors, env)
                  delete_poller.poll_until_finished()
                  self.connectors[env].post('/repositories/%s/actions/publish/' % (repo_name), {'id': 'yum_distributor'})