summaryrefslogtreecommitdiff
path: root/compose/parallel.py
diff options
context:
space:
mode:
authorEvan Shaw <evan@vendhq.com>2017-02-26 19:19:38 +1300
committerEvan Shaw <evan@vendhq.com>2017-02-26 19:24:59 +1300
commita507c7f72088fc4ccf48ea6f34482813c1fb9f81 (patch)
treeeca0844128c0cb331452ed9f430c9d1ec1093c4c /compose/parallel.py
parentb0ba14cdb28a88706d91cc74f13fcbe87ae37da5 (diff)
Colorize statuses in parallel_execute output
'ok' displays in green 'error' displays in red Signed-off-by: Evan Shaw <evan@vendhq.com>
Diffstat (limited to 'compose/parallel.py')
-rw-r--r--compose/parallel.py10
1 files changed, 6 insertions, 4 deletions
diff --git a/compose/parallel.py b/compose/parallel.py
index e495410c..cdeb0725 100644
--- a/compose/parallel.py
+++ b/compose/parallel.py
@@ -11,6 +11,8 @@ from six.moves import _thread as thread
from six.moves.queue import Empty
from six.moves.queue import Queue
+from compose.cli.colors import green
+from compose.cli.colors import red
from compose.cli.signals import ShutdownException
from compose.errors import HealthCheckFailed
from compose.errors import NoHealthCheckConfigured
@@ -45,16 +47,16 @@ def parallel_execute(objects, func, get_name, msg, get_deps=None):
for obj, result, exception in events:
if exception is None:
- writer.write(get_name(obj), 'done')
+ writer.write(get_name(obj), green('done'))
results.append(result)
elif isinstance(exception, APIError):
errors[get_name(obj)] = exception.explanation
- writer.write(get_name(obj), 'error')
+ writer.write(get_name(obj), red('error'))
elif isinstance(exception, (OperationFailedError, HealthCheckFailed, NoHealthCheckConfigured)):
errors[get_name(obj)] = exception.msg
- writer.write(get_name(obj), 'error')
+ writer.write(get_name(obj), red('error'))
elif isinstance(exception, UpstreamError):
- writer.write(get_name(obj), 'error')
+ writer.write(get_name(obj), red('error'))
else:
errors[get_name(obj)] = exception
error_to_reraise = exception