lazy

Author: jph00

fastcore/basics.py

@@ -25,7 +25,7 @@
 
 # %% ../nbs/01_basics.ipynb #0e91ed82
 from .imports import *
-import ast,builtins,pprint,types,typing
+import builtins,types,typing
 from functools import cmp_to_key,wraps
 from copy import copy
 from datetime import date
@@ -279,7 +279,10 @@ def __dir__(self): return super().__dir__() + list(self.keys())
 # %% ../nbs/01_basics.ipynb #28bf9743
 class AttrDict(adict):
     "`dict` subclass that also provides access to keys as attrs, and has a pretty markdown repr"
-    def _repr_markdown_(self): return f'```python\n{pprint.pformat(self, indent=2)}\n```'
+    def _repr_markdown_(self):
+        import pprint
+        return f'```python\n{pprint.pformat(self, indent=2)}\n```'
+
     def copy(self): return AttrDict(**self)
 
 # %% ../nbs/01_basics.ipynb #cb8a0ff4
@@ -1276,6 +1279,7 @@ def str2float(s:str):
 # %% ../nbs/01_basics.ipynb #5d49a6d4
 def str2list(s:str):
     "Convert `s` to a list"
+    import ast
     s = s.strip()
     if not s: return []
     if s[0] != '[': s = '['+s + ']'

fastcore/parallel.py

@@ -14,7 +14,7 @@
 from .xtras import *
 from functools import wraps
 
-import concurrent.futures,time,asyncio
+import concurrent.futures,time
 from multiprocessing import Process,Queue,Manager,set_start_method,get_all_start_methods,get_context
 from threading import Thread
 try:
@@ -156,6 +156,7 @@ def _add_one(x, a=1):
 async def parallel_async(f, items, *args, n_workers=16, pause=0,
                          timeout=None, chunksize=1, on_exc=print, cancel_on_error=False, **kwargs):
     "Applies `f` to `items` in parallel using asyncio and a semaphore to limit concurrency."
+    import asyncio
     semaphore = asyncio.Semaphore(n_workers)
     async def limited_task(i, item):
         coro = f(item, *args, **kwargs) if asyncio.iscoroutinefunction(f) else asyncio.to_thread(f, item, *args, **kwargs)

nbs/01_basics.ipynb

@@ -19,7 +19,7 @@
    "source": [
     "#| export\n",
     "from fastcore.imports import *\n",
-    "import ast,builtins,pprint,types,typing\n",
+    "import builtins,types,typing\n",
     "from functools import cmp_to_key,wraps\n",
     "from copy import copy\n",
     "from datetime import date\n",
@@ -1700,7 +1700,10 @@
     "#| export\n",
     "class AttrDict(adict):\n",
     "    \"`dict` subclass that also provides access to keys as attrs, and has a pretty markdown repr\"\n",
-    "    def _repr_markdown_(self): return f'```python\\n{pprint.pformat(self, indent=2)}\\n```'\n",
+    "    def _repr_markdown_(self):\n",
+    "        import pprint\n",
+    "        return f'```python\\n{pprint.pformat(self, indent=2)}\\n```'\n",
+    "\n",
     "    def copy(self): return AttrDict(**self)"
    ]
   },
@@ -7724,6 +7727,7 @@
     "#| export\n",
     "def str2list(s:str):\n",
     "    \"Convert `s` to a list\"\n",
+    "    import ast\n",
     "    s = s.strip()\n",
     "    if not s: return []\n",
     "    if s[0] != '[': s = '['+s + ']'\n",
@@ -8385,7 +8389,16 @@
    ]
   }
  ],
- "metadata": {},
+ "metadata": {
+  "solveit": {
+   "default_code": false,
+   "mode": "learning",
+   "use_fence": false,
+   "use_thinking": true,
+   "use_tools": true,
+   "ver": 2
+  }
+ },
  "nbformat": 4,
  "nbformat_minor": 5
 }

nbs/02_foundation.ipynb

@@ -4569,7 +4569,16 @@
    ]
   }
  ],
- "metadata": {},
+ "metadata": {
+  "solveit": {
+   "default_code": false,
+   "mode": "learning",
+   "use_fence": false,
+   "use_thinking": true,
+   "use_tools": true,
+   "ver": 2
+  }
+ },
  "nbformat": 4,
  "nbformat_minor": 5
 }

nbs/03a_parallel.ipynb

@@ -25,7 +25,7 @@
     "from fastcore.xtras import *\n",
     "from functools import wraps\n",
     "\n",
-    "import concurrent.futures,time,asyncio\n",
+    "import concurrent.futures,time\n",
     "from multiprocessing import Process,Queue,Manager,set_start_method,get_all_start_methods,get_context\n",
     "from threading import Thread\n",
     "try:\n",
@@ -766,6 +766,7 @@
     "async def parallel_async(f, items, *args, n_workers=16, pause=0,\n",
     "                         timeout=None, chunksize=1, on_exc=print, cancel_on_error=False, **kwargs):\n",
     "    \"Applies `f` to `items` in parallel using asyncio and a semaphore to limit concurrency.\"\n",
+    "    import asyncio\n",
     "    semaphore = asyncio.Semaphore(n_workers)\n",
     "    async def limited_task(i, item):\n",
     "        coro = f(item, *args, **kwargs) if asyncio.iscoroutinefunction(f) else asyncio.to_thread(f, item, *args, **kwargs)\n",