def _deploy_server_group(self, server_group):
        LOG.info("Deploying server_group for tenant %s to destination: %s",
                 server_group['tenant'], server_group['name'])

        try:
            with proxy_client.expect_exception(
                    keystone.ks_exceptions.NotFound):
                tenant_id = self.identity.get_tenant_id_by_name(
                    server_group["tenant"])
        except keystone.ks_exceptions.NotFound:
            LOG.info("Tenant '%s' does not exist on DST. Skipping server group"
                     " '%s' with id='%s'...",
                     server_group['tenant'],
                     server_group['name'],
                     server_group['uuid'])
            return

        sql = SQL_INSERT_GROUP.format(
            server_group['uuid'],
            server_group['name'],
            tenant_id,
            self.identity.try_get_user_by_name(
                server_group["user"], self.config.cloud.user).id,
        )
        self._execute(sql)

        sql = SQL_SELECT_GROUP_ID.format(server_group['uuid'])
        gid = self._execute(sql).fetchone()[0]
        for policy in server_group['policies']:
            sql = SQL_INSERT_POLICY.format(gid, policy)
            self._execute(sql)

        return server_group
Uses the sql connector to do the following:
dataset/ETHPy150Open MirantisWorkloadMobility/CloudFerry/cloudferry/lib/os/compute/server_groups.py/ServerGroupsHandler._deploy_server_group