Merge pull request #492 from dwskoog/python_312_event_loop_warnings

Fix Python 3.12+, Tornado 6.3+ event loop deprecation warnings

Author: martindurant

streamz/core.py

@@ -51,7 +51,7 @@ def get_io_loop(asynchronous=None):
             return client.loop
 
     if not _io_loops:
-        loop = IOLoop()
+        loop = IOLoop(make_current=False)
         thread = threading.Thread(target=loop.start)
         thread.daemon = True
         thread.start()

streamz/tests/test_core.py

@@ -444,7 +444,8 @@ def test_timed_window_metadata():
     ]
 
 
-def test_timed_window_timedelta(clean):  # noqa: F811
+@pytest.mark.asyncio
+async def test_timed_window_timedelta(clean):  # noqa: F811
     pytest.importorskip('pandas')
     source = Stream(asynchronous=True)
     a = source.timed_window('10ms')

streamz/utils_test.py

@@ -43,16 +43,11 @@ def double(x):
 
 @contextmanager
 def pristine_loop():
-    IOLoop.clear_instance()
-    IOLoop.clear_current()
-    loop = IOLoop()
-    loop.make_current()
+    loop = IOLoop(make_current=False)
     try:
         yield loop
     finally:
         loop.close(all_fds=True)
-        IOLoop.clear_instance()
-        IOLoop.clear_current()
 
 
 def gen_test(timeout=10):