formatting

Author: dylanmcreynolds

.github/workflows/publish.yaml

@@ -47,4 +47,4 @@ jobs:
       - name: Publish to PyPI
         uses: pypa/gh-action-pypi-publish@release/v1
         with:
-          password: ${{ secrets.PYPI_API_TOKEN }}
+          password: ${{ secrets.PYPI_API_TOKEN }}

LICENSE.txt

@@ -1,4 +1,4 @@
-Arroyo Stream Processing Toolset (arroyopy) Copyright (c) 2025, The Regents of the University of California, through Lawrence Berkeley National Laboratory (subject to receipt of any required approvals from the U.S. Dept. of Energy). 
+Arroyo Stream Processing Toolset (arroyopy) Copyright (c) 2025, The Regents of the University of California, through Lawrence Berkeley National Laboratory (subject to receipt of any required approvals from the U.S. Dept. of Energy).
 All rights reserved.
 
 Redistribution and use in source and binary forms, with or without
@@ -31,4 +31,3 @@ non-exclusive, royalty-free perpetual license to install, use, modify,
 prepare derivative works, incorporate into other computer software,
 distribute, and sublicense such enhancements or derivative works thereof,
 in binary and source code form.
-

README.md

@@ -206,7 +206,7 @@ pixi r test
 '''
 
 # Copyright
-Arroyo Stream Processing Toolset (arroyopy) Copyright (c) 2025, The Regents of the University of California, through Lawrence Berkeley National Laboratory (subject to receipt of any required approvals from the U.S. Dept. of Energy). 
+Arroyo Stream Processing Toolset (arroyopy) Copyright (c) 2025, The Regents of the University of California, through Lawrence Berkeley National Laboratory (subject to receipt of any required approvals from the U.S. Dept. of Energy).
 All rights reserved.
 
 If you have questions about your rights to use or distribute this software,
@@ -217,5 +217,5 @@ NOTICE.  This Software was developed under funding from the U.S. Department
 of Energy and the U.S. Government consequently retains certain rights.  As
 such, the U.S. Government has been granted for itself and others acting on
 its behalf a paid-up, nonexclusive, irrevocable, worldwide license in the
-Software to reproduce, distribute copies to the public, prepare derivative 
-works, and perform publicly and display publicly, and to permit others to do so.
+Software to reproduce, distribute copies to the public, prepare derivative
+works, and perform publicly and display publicly, and to permit others to do so.

pyproject.toml

@@ -77,12 +77,12 @@ pytest = ">=8.3.3,<9"
 
 
 [project.urls]
-Homepage = "https://github.com/als-computing/als_arroyo"
-Issues = "https://github.com/als-computing/als_arroyo/issues"
+Homepage = "https://github.com/als-computing/arroyopy"
+Issues = "https://github.com/als-computing/arroyopy/issues"
 
 
 [tool.isort]
 profile = "black"
 
 [tool.hatch.metadata]
-allow-direct-references = true
+allow-direct-references = true

src/arroyopy/listener.py

@@ -1,6 +1,5 @@
 import asyncio
 from abc import ABC, abstractmethod
-from typing import Generic, TypeVar
 
 
 class Listener(ABC):

src/arroyopy/operator.py

@@ -1,6 +1,6 @@
-from abc import ABC, abstractmethod
 import asyncio
 import logging
+from abc import ABC, abstractmethod
 from typing import List
 
 from .listener import Listener
@@ -9,6 +9,7 @@
 
 logger = logging.getLogger(__name__)
 
+
 class Operator(ABC):
     listeners: List[Listener] = []
     publishers: List[Publisher] = []
@@ -24,7 +25,7 @@ async def process(self, message: Message) -> None:
     async def add_listener(self, listener: Listener) -> None:  # noqa
         self.listeners.append(listener)
         await listener.start(self.listener_queue)
-    
+
     def remove_listener(self, listener: Listener) -> None:  # noqa
         self.listeners.remove(listener)
 

src/arroyopy/publisher.py

@@ -3,10 +3,10 @@
 
 from .schemas import Message
 
-T = TypeVar('T', bound=Message)
+T = TypeVar("T", bound=Message)
 
-class Publisher(ABC, Generic[T]):
 
+class Publisher(ABC, Generic[T]):
     @abstractmethod
     async def publish(self, message: Message) -> None:
         pass

src/arroyopy/schemas.py

@@ -1,5 +1,3 @@
-from typing import Tuple
-
 import numpy
 import numpy.typing
 import pandas