refining the capture_output_stream script to allow standalone execution

Author: brandonjbjelland

requirements.txt

@@ -1,6 +1,5 @@
 appnope==0.1.3
 asttokens==2.2.1
-asyncio==3.4.3
 attrs==23.1.0
 backcall==0.2.0
 black==23.7.0
@@ -27,7 +26,6 @@ iniconfig==2.0.0
 ipykernel==6.24.0
 ipython==8.14.0
 isort==5.12.0
-janus==1.0.0
 jedi==0.18.2
 jsonschema==4.18.4
 jsonschema-specifications==2023.7.1
@@ -54,7 +52,6 @@ pyasn1==0.5.0
 pyasn1-modules==0.3.0
 Pygments==2.15.1
 pytest==7.4.0
-pytest-asyncio==0.21.1
 pytest-dependency==0.5.1
 python-dateutil==2.8.2
 pyzmq==25.1.0

tests/capture_output_stream.py

@@ -4,6 +4,7 @@
 """
 
 import logging
+import time
 from jupyter_client.blocking.client import BlockingKernelClient
 from watchdog.observers import Observer
 from watchdog.events import FileSystemEventHandler
@@ -113,7 +114,20 @@ def start_watches():
 
 
 def main():
-    start_watches()
+    logging.basicConfig(
+        level=logging.INFO, format="%(levelname)s:%(name)s:%(message)s"
+    )  # Configure logging here
+    threads, stop_event = start_watches()
+
+    try:
+        while True:  # Keep the script running
+            time.sleep(1)
+    except KeyboardInterrupt:
+        stop_event.set()  # Signal the threads to stop
+        for thread in threads:
+            thread.join()  # Wait for all threads to finish
+
+    print("Exiting...")
 
 
 if __name__ == "__main__":

tests/conftest.py

@@ -10,7 +10,7 @@
 import logging
 from capture_output_stream import start_watches
 
-logging.basicConfig(level=logging.INFO, format="%(levelname)s:%(name)s:%(message)s")
+logging.basicConfig(level=logging.INFO, format="%(levelname)s:%(name)s: %(message)s")
 logger = logging.getLogger(__name__)