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):