async def METHOD_NAME(self, format_version, batch_id, job_id, attempt_id, task) -> bytes:
    url = self.log_path(format_version, batch_id, job_id, attempt_id, task)
    return await self.fs.read(url)