uniworx/k8s-gitlab-borg
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 4 Wiki Activity

more logging

Browse Source
This commit is contained in:
Gregor Kleen 2023-05-29 17:18:16 +02:00
parent 1003ca01bd
commit 95973ae2c8
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
k8s_gitlab_borg/__main__.py
View File

@ -513,10 +513,14 @@ def main():
if chunk := proc.stdout.buffer.read(PIPE_BUF): if chunk := proc.stdout.buffer.read(PIPE_BUF):
logger.debug("Done, length %d", len(chunk)) logger.debug("Done, length %d", len(chunk))
stdout_line_buffer.extend(chunk) stdout_line_buffer.extend(chunk)
logger.debug(
"Buffer at length %d", len(stdout_line_buffer)
)
while True: while True:
line, sep, rest = stdout_line_buffer.partition( line, sep, rest = stdout_line_buffer.partition(
b"\n" b"\n"
) )
logger.debug("Split: %r, %r, %r", line, sep, rest)
if sep: if sep:
stdout_logger.info(line) stdout_logger.info(line)
stdout_line_buffer = rest stdout_line_buffer = rest
@ -527,10 +531,14 @@ def main():
if chunk := proc.stderr.buffer.read(PIPE_BUF): if chunk := proc.stderr.buffer.read(PIPE_BUF):
logger.debug("Done, length %d", len(chunk)) logger.debug("Done, length %d", len(chunk))
stderr_line_buffer.extend(chunk) stderr_line_buffer.extend(chunk)
logger.debug(
"Buffer at length %d", len(stderr_line_buffer)
)
while True: while True:
line, sep, rest = stderr_line_buffer.partition( line, sep, rest = stderr_line_buffer.partition(
b"\n" b"\n"
) )
logger.debug("Split: %r, %r, %r", line, sep, rest)
if sep: if sep:
stderr_logger.info(line) stderr_logger.info(line)
stderr_line_buffer = rest stderr_line_buffer = rest