Handle warnings

Author: blink1073

ipykernel/eventloops.py

@@ -6,7 +6,7 @@
 import os
 import platform
 import sys
-from distutils.version import LooseVersion as V
+from pkg_resources import parse_version as V
 from functools import partial
 
 import zmq

ipykernel/tests/conftest.py

@@ -0,0 +1,21 @@
+
+try:
+    import resource
+except ImportError:
+    # Windows
+    resource = None
+
+
+# Handle resource limit
+# Ensure a minimal soft limit of DEFAULT_SOFT if the current hard limit is at least that much.
+if resource is not None:
+    soft, hard = resource.getrlimit(resource.RLIMIT_NOFILE)
+
+    DEFAULT_SOFT = 4096
+    if hard >= DEFAULT_SOFT:
+        soft = DEFAULT_SOFT
+
+    if hard < soft:
+        hard = soft
+
+    resource.setrlimit(resource.RLIMIT_NOFILE, (soft, hard))

ipykernel/tests/test_embed_kernel.py

@@ -75,6 +75,12 @@ def connection_file_ready(connection_file):
             client.stop_channels()
     finally:
         kernel.terminate()
+        kernel.wait()
+        # Make sure all the fds get closed.
+        for attr in ['stdout', 'stderr', 'stdin']:
+            fid = getattr(kernel, attr)
+            if fid:
+                fid.close()
 
 
 @flaky(max_runs=3)

ipykernel/tests/test_message_spec.py

@@ -5,12 +5,12 @@
 
 import re
 import sys
-from distutils.version import LooseVersion as V
+from pkg_resources import parse_version as V
 from queue import Empty
 
 import jupyter_client
 import pytest
-from traitlets import Bool, Dict, Enum, HasTraits, Integer, List, TraitError, Unicode
+from traitlets import Bool, Dict, Enum, HasTraits, Integer, List, TraitError, Unicode, observe
 
 from .utils import TIMEOUT, execute, flush_channels, get_reply, start_global_kernel
 
@@ -98,8 +98,9 @@ class MimeBundle(Reference):
     metadata = Dict()
     data = Dict()
 
-    def _data_changed(self, name, old, new):
-        for k, v in new.items():
+    @observe('data')
+    def _on_data_changed(self, change):
+        for k, v in change['new'].items():
             assert mime_pat.match(k)
             assert isinstance(v, str)
 

ipykernel/tests/test_pickleutil.py

@@ -1,6 +1,10 @@
 import pickle
+import warnings
 
-from ipykernel.pickleutil import can, uncan
+
+with warnings.catch_warnings():
+    warnings.simplefilter("ignore")
+    from ipykernel.pickleutil import can, uncan
 
 
 def interactive(f):

pyproject.toml

@@ -37,3 +37,11 @@ testpaths = [
 timeout = 300
 # Restore this setting to debug failures
 # timeout_method = "thread"
+filterwarnings= [
+  # Fail on warnings
+  "error",
+
+  # Workarounds jupyter_client
+  "ignore:unclosed <socket.socket:ResourceWarning",
+  "ignore:unclosed event loop:ResourceWarning",
+]

setup.py

@@ -62,19 +62,20 @@ def run(self):
     keywords=["Interactive", "Interpreter", "Shell", "Web"],
     python_requires=">=3.7",
     install_requires=[
-        "debugpy>=1.0.0,<2.0",
+        "debugpy>=1.0",
         "ipython>=7.23.1",
-        "traitlets>=5.1.0,<6.0",
-        "jupyter_client<8.0",
-        "tornado>=5.0,<7.0",
-        "matplotlib-inline>=0.1.0,<0.2.0",
+        "traitlets>=5.1.0",
+        "jupyter_client>=6.1.12",
+        "tornado>=6.1",
+        "matplotlib-inline>=0.1",
         'appnope;platform_system=="Darwin"',
         "psutil",
         "nest_asyncio",
+        "setuptools>=60"  # for pkg_resources
     ],
     extras_require={
         "test": [
-            "pytest !=5.3.4",
+            "pytest>=6.0",
             "pytest-cov",
             "flaky",
             "ipyparallel",
@@ -92,6 +93,7 @@ def run(self):
         "Programming Language :: Python :: 3.7",
         "Programming Language :: Python :: 3.8",
         "Programming Language :: Python :: 3.9",
+        "Programming Language :: Python :: 3.10",
     ],
 )