| 225 | self.source = bytes(memoryview(buf)) |
| 226 | |
| 227 | def process_vy_object(self, source): |
| 228 | self.protocol = "vineyard" |
| 229 | # encoding: add a `o` prefix to object id, and a `s` prefix to object name. |
| 230 | if isinstance(source, vineyard.Object): |
| 231 | self.source = "o%s" % repr(source.id) |
| 232 | elif isinstance(source, vineyard.ObjectID): |
| 233 | self.source = "o%s" % repr(source) |
| 234 | elif isinstance(source, vineyard.ObjectName): |
| 235 | self.source = "s%s" % str(source) |
| 236 | else: |
| 237 | raise ValueError( |
| 238 | "Invalid input source: not a vineyard's Object, ObjectID or ObjectName" |
| 239 | ) |
| 240 | |
| 241 | def select_columns(self, columns: Sequence[Tuple[str, int]], include_all=False): |
| 242 | self.options.include_columns = [] |