corbz/Spiffo
Archived
1
0
Fork 0
Code Issues 1 Pull Requests Actions Activity

fix improper generator use
All checks were successful
Build and Push Docker Image / build (push) Successful in 12s
Details

Browse Source
This commit is contained in:
Corban-Lee Jones 2024-12-08 00:46:57 +00:00
parent 3e8072fb67
commit c398cac067
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
utils/reader.py
View File

@ -21,7 +21,7 @@ class LogFileReader:
self._last_line_number = 0 self._last_line_number = 0
log.debug("%s created with path %s", self.__class__.__name__, str(file_path)) log.debug("%s created with path %s", self.__class__.__name__, str(file_path))
async def read(self): async def read(self) -> list[str]:
if not self.file_path.exists(): if not self.file_path.exists():
log.error("Cannot read non-existant file path: '%s'", self.file_path) log.error("Cannot read non-existant file path: '%s'", self.file_path)
raise FileNotFoundError(self.file_path) raise FileNotFoundError(self.file_path)
@ -30,17 +30,13 @@ class LogFileReader:
if self._last_line_number == 0: if self._last_line_number == 0:
await file.seek(0, 2) await file.seek(0, 2)
self._last_line_number = await file.tell() self._last_line_number = await file.tell()
return return []
await file.seek(self._last_line_number) await file.seek(self._last_line_number)
lines = await file.readlines() lines = await file.readlines()
if not lines: if not lines:
log.debug("no new lines to read") log.debug("no new lines to read")
return return []
self._last_line_number = await file.tell() self._last_line_number = await file.tell()
return lines
log.debug("lines to yield: %s", len(lines))
for line in lines:
yield line.strip()