(self, path: str)
| 59 | return cnt |
| 60 | |
| 61 | async def load_flows_from_path(self, path: str) -> int: |
| 62 | path = os.path.expanduser(path) |
| 63 | try: |
| 64 | with open(path, "rb") as f: |
| 65 | return await self.load_flows(f) |
| 66 | except OSError as e: |
| 67 | logging.error(f"Cannot load flows: {e}") |
| 68 | raise exceptions.FlowReadException(str(e)) from e |
| 69 | |
| 70 | async def doread(self, rfile: str) -> None: |
| 71 | try: |