logos-messaging/logos-messaging-interop-tests
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-interop-tests.git synced 2026-01-05 23:43:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

log fix

Browse Source
This commit is contained in:
Florin Barbu 2024-10-23 11:44:24 +03:00
parent bd2651421d
commit 14e28439bb
No known key found for this signature in database
GPG Key ID: 593D6DBC6D9E5095
1 changed files with 24 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/node/docker_mananger.py
View File

@ -1,12 +1,13 @@
import os
import re
import time
from src.libs.custom_logger import get_custom_logger
import random
import threading
import docker
from src.env_vars import NETWORK_NAME, SUBNET, IP_RANGE, GATEWAY
from docker.types import IPAMConfig, IPAMPool
from docker.errors import NotFound
from docker.errors import NotFound, APIError
logger = get_custom_logger(__name__)
@ -63,9 +64,28 @@ class DockerManager:
def _log_container_output(self, container, log_path):
os.makedirs(os.path.dirname(log_path), exist_ok=True)
try:
with open(log_path, "wb+") as log_file:
start_time = time.time()
while True:
if container.status in ["exited", "dead"]:
logger.info(f"Container {container.short_id} has stopped. Exiting log stream.")
return
try:
for chunk in container.logs(stream=True):
if chunk:
log_file.write(chunk)
log_file.flush()
start_time = time.time()
else:
if time.time() - start_time > 10:
logger.error(f"Log stream timeout for container {container.short_id}")
return
except (APIError, IOError) as e:
logger.error(f"Error while reading logs from container {container.short_id}: {e}")
time.sleep(1)
except Exception as e:
logger.error(f"Failed to set up logging for container {container.short_id}: {e}")
def generate_ports(self, base_port=None, count=5):
if base_port is None: