commit ca16f38e880d60c9721566251597cc9aae1f9778
author Philip Jägenstedt <philip@foolip.org> Thu May 07 10:51:50 2020
committer GitHub <noreply@github.com> Thu May 07 10:51:50 2020
tree c3ed65697cba428ce4f23f0fbcd4b121b960d3bb
parent 663e39d65620ff336e5183b0b4c2a7bb1636c2c7

Let retry.py flush stdout after each log message (#19754)

This is to avoid the subprocess output appearing before the
"Running %s [try %d/%d]" message.

.taskcluster.yml

diff --git a/.taskcluster.yml b/.taskcluster.yml
index 7f794e8..f837103 100644
--- a/.taskcluster.yml
+++ b/.taskcluster.yml
@@ -56,7 +56,7 @@
             owner: ${owner}
             source: ${event.repository.clone_url}
           payload:
-            image: webplatformtests/wpt:0.36
+            image: webplatformtests/wpt:0.37
             maxRunTime: 7200
             artifacts:
               public/results:

tools/ci/tc/tasks/test.yml

diff --git a/tools/ci/tc/tasks/test.yml b/tools/ci/tc/tasks/test.yml
index 3157fb6..6e22cc5 100644
--- a/tools/ci/tc/tasks/test.yml
+++ b/tools/ci/tc/tasks/test.yml
@@ -4,7 +4,7 @@
     workerType: ci
     schedulerId: taskcluster-github
     deadline: "24 hours"
-    image: webplatformtests/wpt:0.36
+    image: webplatformtests/wpt:0.37
     maxRunTime: 7200
     artifacts:
       public/results:

tools/docker/retry.py

diff --git a/tools/docker/retry.py b/tools/docker/retry.py
index 6126b78..5c8e6d7 100755
--- a/tools/docker/retry.py
+++ b/tools/docker/retry.py
@@ -21,23 +21,28 @@
         i += 1
 
 
+def log(value):
+    print(value)
+    sys.stdout.flush()
+
+
 def main():
     args = get_args().parse_args()
 
     if not args.cmd:
-        print("No command supplied")
+        log("No command supplied")
         sys.exit(1)
 
     retcode = None
 
     for n in iter_range(args.count):
         try:
-            print("Running %s [try %d/%d]" % (" ".join(args.cmd), (n+1), args.count))
+            log("Running %s [try %d/%d]" % (" ".join(args.cmd), (n+1), args.count))
             subprocess.check_call(args.cmd)
         except subprocess.CalledProcessError as e:
             retcode = e.returncode
         else:
-            print("Command succeeded")
+            log("Command succeeded")
             retcode = 0
             break
 
@@ -46,10 +51,10 @@
         else:
             wait_time = args.factor**n * args.delay
         if n < args.count - 1:
-            print("Command failed, waiting %s seconds to retry" % wait_time)
+            log("Command failed, waiting %s seconds to retry" % wait_time)
             time.sleep(wait_time)
         else:
-            print("Command failed, out of retries")
+            log("Command failed, out of retries")
 
     sys.exit(retcode)