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'})