pre-commit run --all-files

docs/getting_started/simple_builder.md

@@ -112,7 +112,7 @@ One advantage of using the generator approach is it is less memory intensive tha
 
 `process_item` just has to do the parallelizable work on each item. Since the item is whatever comes out of `get_items`, you know exactly what it should be. It may be a single document, a list of documents, a mapping, a set, etc.
 
-Our simple process item just has to multiply one field by `self.mulitplier`:
+Our simple process item just has to multiply one field by `self.multiplier`:
 
 ``` python
 

src/maggma/__init__.py

@@ -1,4 +1,5 @@
 """Primary Maggma module."""
+
 from importlib.metadata import PackageNotFoundError, version
 
 try:

src/maggma/cli/multiprocessing.py

@@ -85,8 +85,9 @@ async def get_from_iterator(self):
             future = loop.run_in_executor(self.executor, safe_dispatch, (self.func, item))
 
             self.tasks[idx] = future
-
-            loop.create_task(self.process_and_release(idx))
+            # TODO - line below raises RUF006 error. Unsure about the best way to
+            # resolve. See https://docs.astral.sh/ruff/rules/asyncio-dangling-task/
+            loop.create_task(self.process_and_release(idx))  # noqa: RUF006
 
         await gather(*self.tasks.values())
         self.results.put_nowait(self.done_sentinel)

tests/builders/test_copy_builder.py

@@ -1,6 +1,7 @@
 """
 Tests for MapBuilder
 """
+
 from datetime import datetime, timedelta
 
 import pytest

tests/builders/test_group_builder.py

@@ -1,6 +1,7 @@
 """
 Tests for group builder
 """
+
 from datetime import datetime
 from random import randint
 

tests/stores/test_advanced_stores.py

@@ -1,6 +1,7 @@
 """
 Tests for advanced stores
 """
+
 import os
 import shutil
 import signal

tests/test_utils.py

@@ -1,6 +1,7 @@
 """
 Tests for builders
 """
+
 from datetime import datetime
 from time import sleep
 

tests/test_validator.py

@@ -1,6 +1,7 @@
 """
 Tests the validators
 """
+
 import pytest
 from monty.json import MSONable