(self, path)
| 126 | assert dest == "copy_file_to" |
| 127 | |
| 128 | def open_input_stream(self, path): |
| 129 | if "notfound" in path: |
| 130 | raise FileNotFoundError(path) |
| 131 | data = f"{path}:input_stream".encode('utf8') |
| 132 | return pa.BufferReader(data) |
| 133 | |
| 134 | def open_input_file(self, path): |
| 135 | if "notfound" in path: |
no test coverage detected