From 329de53c7c8cea725249089df87d6cd9823f6972 Mon Sep 17 00:00:00 2001 From: Lars-Dominik Braun Date: Tue, 25 Sep 2018 16:16:31 +0200 Subject: Immediately flush logger Consumers can read the latest gossip faster now. --- crocoite/logger.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/crocoite/logger.py b/crocoite/logger.py index 4b43e02..e8ff594 100644 --- a/crocoite/logger.py +++ b/crocoite/logger.py @@ -97,6 +97,7 @@ class PrintConsumer (Consumer): def __call__ (self, **kwargs): sys.stderr.write (str (kwargs)) sys.stderr.write ('\n') + sys.stderr.flush () return kwargs class JsonEncoder (json.JSONEncoder): @@ -118,6 +119,7 @@ class JsonPrintConsumer (Consumer): if kwargs['level'] >= self.minLevel: json.dump (kwargs, sys.stdout, cls=JsonEncoder) sys.stdout.write ('\n') + sys.stdout.flush () return kwargs class DatetimeConsumer (Consumer): -- cgit v1.2.3