BUG: Add using nest-asyncio to fix the issue with running in Jupyter …

…notebooks. [skip ci]

pyproject.toml

@@ -40,6 +40,7 @@ dependencies = [
   "aiofiles",
   "aiohttp>=3.8.3",
   "click>=0.7",
+  "nest-asyncio",
   "netcdf4",
   "numpy>=2",
   "pandas>=1",

src/pygridmet/_streaming.py

@@ -58,13 +58,33 @@ async def _stream_session(urls: Sequence[str], files: Sequence[Path]) -> None:
         await asyncio.gather(*tasks)
 
 
+def is_jupyter_kernel():
+    """Check if the code is running in a Jupyter kernel (not IPython terminal)."""
+    try:
+        from IPython import get_ipython
+
+        ipython = get_ipython()
+    except (ImportError, NameError):
+        return False
+    if ipython is None:
+        return False
+    return "Terminal" not in ipython.__class__.__name__
+
+
 def _get_or_create_event_loop() -> tuple[asyncio.AbstractEventLoop, bool]:
-    """Retrieve or create an event loop."""
-    with contextlib.suppress(RuntimeError):
-        return asyncio.get_running_loop(), False
-    new_loop = asyncio.new_event_loop()
-    asyncio.set_event_loop(new_loop)
-    return new_loop, True
+    """Create an event loop."""
+    try:
+        loop = asyncio.get_running_loop()
+        new_loop = False
+    except RuntimeError:
+        loop = asyncio.new_event_loop()
+        new_loop = True
+    asyncio.set_event_loop(loop)
+    if is_jupyter_kernel():
+        import nest_asyncio
+
+        nest_asyncio.apply(loop)
+    return loop, new_loop
 
 
 def stream_write(urls: Sequence[str], file_paths: Sequence[Path]) -> None: