def METHOD_NAME(shard_id):
    context.attributes['shard_id'] = shard_id
    result = self._connection_from_session(
        mapper=self._mapper_zero(),
        shard_id=shard_id).execute(
        context.statement,
        self._params)
    return self.instances(result, context)