diff options
author | Evan Shaw <evan@vendhq.com> | 2017-02-26 19:19:38 +1300 |
---|---|---|
committer | Evan Shaw <evan@vendhq.com> | 2017-02-26 19:24:59 +1300 |
commit | a507c7f72088fc4ccf48ea6f34482813c1fb9f81 (patch) | |
tree | eca0844128c0cb331452ed9f430c9d1ec1093c4c /compose/parallel.py | |
parent | b0ba14cdb28a88706d91cc74f13fcbe87ae37da5 (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.py | 10 |
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 |