(self, file)
| 77 | self.path = Path(file_uri_to_path(uri)) |
| 78 | |
| 79 | def _store_in_thread(self, file): |
| 80 | dirname = self.path.parent |
| 81 | if dirname and not dirname.exists(): |
| 82 | dirname.mkdir(parents=True) |
| 83 | with self.path.open("ab") as output_file: |
| 84 | output_file.write(file.read()) |
| 85 | |
| 86 | file.close() |
| 87 | |
| 88 | |
| 89 | class FailingBlockingFeedStorage(DummyBlockingFeedStorage): |