Fighting with IO/Subprocess

src/rkd/__init__.py

@@ -58,7 +58,7 @@ def main():
         app.main(argv=sys.argv)
     except TaskNotFoundException as e:
         print(e)
-        sys.exit(1)
+        sys.exit(127)
 
 
 if __name__ == '__main__':

src/rkd/inputoutput.py

@@ -206,6 +206,21 @@ def error_msg(self, text):
     def info_msg(self, text):
         self.opt_outln("\x1B[93m%s\x1B[0m" % text)
 
+    #
+    # Standard formatting
+    #
+    def h1(self, text):
+        self.opt_outln("\x1B[93m  ##> %s\x1B[0m" % text)
+
+    def h2(self, text):
+        self.opt_outln("\x1B[93m   ===> %s\x1B[0m" % text)
+
+    def h3(self, text):
+        self.opt_outln("\x1B[33m    --> %s\x1B[0m" % text)
+
+    def h4(self, text):
+        self.opt_outln("\x1B[33m     ... %s\x1B[0m" % text)
+
 
 class SystemIO(IO):
     """ Used for logging outside of tasks """

src/rkd/standardlib/docker.py

@@ -91,7 +91,7 @@ def configure_argparse(self, parser: ArgumentParser):
         parser.add_argument('--without-global-latest', '-wgl', help='Do not tag :latest', action='store_true')
         parser.add_argument('--propagate', '-p', help='Propagate tags? eg. 1.0.0 -> 1.0 -> 1 -> latest', action='store_true')
         parser.add_argument('--allowed-meta', '-m', help='Allowed meta part eg. rc, alpha, beta',
-                            default='rc,alpha,stable,dev,prod,test,beta,build,b,snapshot')
+                            default='rc,alpha,stable,dev,prod,test,beta,build,b')
 
 
 class TagImageTask(DockerBaseTask):

src/rkd/taskutil.py

@@ -56,27 +56,29 @@ def sh(self, cmd: str, capture: bool = False, verbose: bool = False, strict: boo
         os.close(write)
 
         if not capture:
-            process = Popen('bash', shell=True, stdin=read, stdout=SUBPROCESS_PIPE, stderr=SUBPROCESS_STDOUT)
-
-            stdout_thread = Thread(target=self._copy_stream, args=(process.stdout, sys.stdout, process))
-            stdout_thread.daemon = True
-            stdout_thread.start()
-            stderr = ''
-
-            exit_code = process.wait()
-
-            if exit_code > 0:
-                raise CalledProcessError(exit_code, cmd, None, stderr)
-
+            # process = Popen('bash', shell=True, stdin=read, stdout=SUBPROCESS_PIPE, stderr=SUBPROCESS_STDOUT, bufsize=1)
+            #
+            # stdout_thread = Thread(target=self._copy_stream, args=(process.stdout, sys.stdout, process))
+            # stdout_thread.daemon = True
+            # stdout_thread.start()
+            #
+            # exit_code = process.wait()
+            #
+            # if exit_code > 0:
+            #     raise CalledProcessError(exit_code, cmd)
+
+            check_call('bash', shell=True, stdin=read)
             return
 
         return check_output('bash', shell=True, stdin=read).decode('utf-8')
 
-    @staticmethod
-    def _copy_stream(in_stream, out_stream, process: Popen):
-        while process.poll() is None:
-            for line in iter(in_stream.readline, ''):
-                out_stream.write(line.decode('utf-8'))
+    # @staticmethod
+    # def _copy_stream(in_stream, out_stream, process: Popen):
+    #     while process.poll() is None:
+    #         for line in iter(in_stream.readline, ''):
+    #             out_stream.write(line.decode('utf-8'))
+    #
+    #     out_stream.write(in_stream.read().decode('utf-8'))
 
     def exec(self, cmd: str, capture: bool = False, background: bool = False) -> Union[str, None]:
         """ Starts a process in shell. Throws exception on error.