added flush

test_tube/log.py

@@ -105,6 +105,7 @@ def __init__(
         self.exp_hash = '{}_v{}'.format(self.name, version)
         self.created_at = str(datetime.utcnow())
         self.rank = rank
+        self.process = os.getpid()
 
         # when debugging don't do anything else
         if debug:
@@ -166,6 +167,13 @@ def on_exit(self):
         if self.rank == 0:
             self.close()
 
+    def __clean_dir(self):
+        files = os.listdir(self.log_dir)
+        print(files)
+        for f in files:
+            if self.process in f:
+                pass
+
     def argparse(self, argparser):
         parsed = vars(argparser)
         to_add = {}