bump versioning to 0.9.1 in prep of next release (#394)

* bump versioning to 0.9.1 in prep of next release

* add noqas

* add another noqa because i give up

README.md

@@ -3,7 +3,7 @@
 # Python Stream Processing Fork
 
 ![python versions](https://img.shields.io/badge/python-3.7%20%7C%203.8%20%7C%203.9%20%7C%203.10-blue)
-![version](https://img.shields.io/badge/version-0.9.0-green)
+![version](https://img.shields.io/badge/version-0.9.1-green)
 [![codecov](https://codecov.io/gh/faust-streaming/faust/branch/master/graph/badge.svg?token=QJFBYNN0JJ)](https://codecov.io/gh/faust-streaming/faust)
 [![slack](https://img.shields.io/badge/slack-Faust-brightgreen.svg?logo=slack)](https://fauststream.slack.com/)
 [![Code style: black](https://img.shields.io/badge/code%20style-black-000000.svg)](https://github.com/psf/black)

docs/includes/tags.txt

@@ -1,4 +1,4 @@
-:Version: 0.9.0
+:Version: 0.9.1
 :Web: https://faust-streaming.github.io/faust
 :Download: https://pypi.org/project/faust-streaming
 :Source: https://github.com/faust-streaming/faust

faust/__init__.py

@@ -23,7 +23,7 @@
 import typing
 from typing import Any, Mapping, NamedTuple, Optional, Sequence, Tuple
 
-__version__ = "0.9.0"
+__version__ = "0.9.1"
 __author__ = "Robinhood Markets, Inc."
 __contact__ = "schrohm@gmail.com, vpatki@wayfair.com"
 __homepage__ = "https://github.com/faust-streaming/faust"

faust/cli/base.py

@@ -592,8 +592,8 @@ def __init__(self, ctx: click.Context, *args: Any, **kwargs: Any) -> None:
         self._blocking_timeout = self.state.blocking_timeout
         self._console_port = self.state.console_port
 
-    @no_type_check  # Subclasses can omit *args, **kwargs in signature.
-    async def run(self, *args: Any, **kwargs: Any) -> Any:
+    @no_type_check  # Subclasses can omit *args, **kwargs in signature.  # noqa: B027
+    async def run(self, *args: Any, **kwargs: Any) -> Any:  # noqa: B027
         """Override this method to define what your command does."""
         # NOTE: If you override __call__ below, you have a non-async command.
         # This is used by .worker to call the
@@ -607,7 +607,7 @@ async def execute(self, *args: Any, **kwargs: Any) -> Any:
         finally:
             await self.on_stop()
 
-    async def on_stop(self) -> None:
+    async def on_stop(self) -> None:  # noqa: B027
         """Call after command executed."""
         ...
 
@@ -629,7 +629,7 @@ def run_using_worker(self, *args: Any, **kwargs: Any) -> NoReturn:
         self.on_worker_created(worker)
         raise worker.execute_from_commandline()
 
-    def on_worker_created(self, worker: Worker) -> None:
+    def on_worker_created(self, worker: Worker) -> None:  # noqa: B027
         """Call when creating :class:`faust.Worker` to execute this command."""
         ...
 

faust/models/typing.py

@@ -271,7 +271,7 @@ def __init__(self, expr: Type, root: "RootNode" = None) -> None:
         if DEBUG:
             print(f"NODE {self!r}")
 
-    def __post_init__(self) -> None:
+    def __post_init__(self) -> None:  # noqa: B027
         ...
 
     def random_identifier(self, n: int = 8) -> str:

faust/types/settings/base.py

@@ -175,7 +175,7 @@ def _on_after_init(self) -> None:
         object.__setattr__(self, "_accessed", set())
         object.__setattr__(self, "_initializing", False)
 
-    def __post_init__(self) -> None:
+    def __post_init__(self) -> None:  # noqa: B027
         ...
 
     def __getattribute__(self, key: str) -> Any: