Sklearn import style (#28)

* deprecate 3.8 here too

* sklearn style

* sklearn style

* sklearn style

* enhance readability

* expand to README too

.github/workflows/deploy-tests.yml

@@ -3,13 +3,11 @@ name: Deploy tests
 on:
   pull_request:
 
-jobs:
-  cancel-previous-runs:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Cancel Previous Runs
-        uses: styfle/[email protected]
+concurrency:  # Cancel previous workflows on the same pull request
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
 
+jobs:
   assess-file-changes:
     uses: catalystneuro/tqdm_publisher/.github/workflows/assess-file-changes.yml@main
 

README.md

@@ -38,8 +38,8 @@ async def run_multiple_sleeps(sleep_durations):
 
     progress_bar.unsubscribe(callback_id)
 
-n = 10**5
-sleep_durations = [random.uniform(0, 5.0) for _ in range(n)]
+number_of_tasks = 10**5
+sleep_durations = [random.uniform(0, 5.0) for _ in range(number_of_tasks)]
 asyncio.run(run_multiple_sleeps(sleep_durations=sleep_durations))
 ```
 

pyproject.toml

@@ -14,7 +14,7 @@ authors = [
 ]
 description = "Extends the base tqdm progress bar with a subscribe method that can expose updates to external (potentially non-Python) processes."
 readme = "README.md"
-requires-python = ">=3.8"
+requires-python = ">=3.9"
 license = {file = "license.txt"}
 
 keywords = ["tqdm", "progressbar", "progressmeter", "progress", "bar", "meter", "time", "pubsub", "publish-subscribe pattern"]

src/tqdm_publisher/__init__.py

@@ -1 +1,3 @@
-from .publisher import TQDMPublisher
+from ._publisher import TQDMPublisher
+
+__all__ = ["TQDMPublisher"]

src/tqdm_publisher/testing.py

@@ -7,10 +7,10 @@ async def sleep_func(sleep_duration: float = 1) -> float:
 
 
 def create_tasks():
-    n = 10**5
-    sleep_durations = [random.uniform(0, 5.0) for _ in range(n)]
-    tasks = []
+    number_of_tasks = 10**5
+    sleep_durations = [random.uniform(0, 5.0) for _ in range(number_of_tasks)]
 
+    tasks = list()
     for sleep_duration in sleep_durations:
         task = asyncio.create_task(sleep_func(sleep_duration=sleep_duration))
         tasks.append(task)