From 3538545380d1404cf759e19362a51df1985a4a19 Mon Sep 17 00:00:00 2001 From: Felipe Deguchi Date: Thu, 13 Dec 2018 12:04:51 -0200 Subject: [PATCH] =?UTF-8?q?Atualiza=C3=A7=C3=A3o=20do=20m=C3=A9todo=20star?= =?UTF-8?q?t?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Receber um parâmetro adicional para dizer se a aplicação deve ou não iniciar o logger, evitando ter que adicionar o método stop_logger na linha seguinte, fazendo com que seja impresso a primeira linha do log --- nbthread_spark/stream.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/nbthread_spark/stream.py b/nbthread_spark/stream.py index d4f2af3..2b995a3 100644 --- a/nbthread_spark/stream.py +++ b/nbthread_spark/stream.py @@ -40,7 +40,8 @@ def run_stream_into_thread(self, thread_print): self.thread.watch() self.query.awaitTermination() - def start(self): + def start(self, logger_enabled=True): + self.log_running = logger_enabled self.thread.start() def stop(self):