Proper log streaming

restic_volume_backup/backup_runner.py

@@ -1,4 +1,5 @@
 import os
+import sys
 import time
 import docker
 
@@ -14,21 +15,22 @@ def run(image: str = None, command: str = None, volumes: dict = None,
         image,
         command,
         labels=labels,
-        auto_remove=True,
+        # auto_remove=True,
         detach=True,
         environment=enviroment,
         volumes=volumes,
         working_dir=os.getcwd(),
+        tty=True,
     )
 
     print("Backup process container:", container.name)
-    logs = container.logs(stdout=True, stderr=True, stream=True)
+    log_generator = container.logs(stdout=True, stderr=True, stream=True, follow=True)
-    try:
+    with open('backup.log', 'w') as fd:
-        while True:
+        for line in log_generator:
-            time.sleep(3)
+            line = line.decode()
-            for line in logs:
+            fd.write(line)
-                print(line.decode(), end='')
+            print(line, end='')
-            # Raises requests.exceptions.HTTPError if continer is dead
+
-            container.top()
+    container.reload()
-    except Exception as ex:
+    print("ExitCode", container.attrs['State']['ExitCode'])
-        print("Container stopped")
+    container.remove()