diff --git a/deploy/docker/fs/usr/lib/python3/dist-packages/supervisor/appsmith_supervisor_stdout.py b/deploy/docker/fs/usr/lib/python3/dist-packages/supervisor/appsmith_supervisor_stdout.py index 966c7f13d9..39ffd0f17c 100644 --- a/deploy/docker/fs/usr/lib/python3/dist-packages/supervisor/appsmith_supervisor_stdout.py +++ b/deploy/docker/fs/usr/lib/python3/dist-packages/supervisor/appsmith_supervisor_stdout.py @@ -8,33 +8,24 @@ Originally taken from https://github.com/coderanger/supervisor-stdout/blob/973ba import sys -def write_stdout(s): - sys.stdout.write(s) - sys.stdout.flush() - - -def write_stderr(s): - sys.stderr.write(s) - sys.stderr.flush() - - def main(): while 1: - write_stdout("READY\n") # transition from ACKNOWLEDGED to READY + print("READY", flush=True) # transition from ACKNOWLEDGED to READY line = sys.stdin.readline() # read header line from stdin headers = dict([x.split(":") for x in line.split()]) data = sys.stdin.read(int(headers["len"])) # read the event payload - write_stdout( - "RESULT %s\n%s" % (len(data.encode("utf-8")), data) + print( + f"RESULT {len(data.encode('utf-8'))}\n{data}", + end="", + flush=True, ) # transition from READY to ACKNOWLEDGED def event_handler(event, response): - line, data = response.rstrip().decode().split("\n", 1) + line, *lines = response.rstrip().decode().split("\n", 1) headers = dict(x.split(":", 1) for x in line.split()) - lines = data.split("\n") - prefix = "%s %s | " % (headers["processname"], headers["channel"]) - print("\n".join(prefix + l for l in lines)) + prefix = f"{headers['processname']} {headers['channel']} | " + print(*(prefix + l for l in lines), sep="\n", file=sys.stderr, flush=True) if __name__ == "__main__":