diff --git a/CHANGELOG.md b/CHANGELOG.md index 4c3436c..9df4a4a 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,4 +1,7 @@ ## 2.2.x +### 2.2.1 +#### Bugfix +* Fixed bug in *match()* method of *Routing* class ### 2.2.0 #### Features * Added *to_dict()* method to Results class diff --git a/routingfilter/routing.py b/routingfilter/routing.py index b4fd2ff..77f9e33 100644 --- a/routingfilter/routing.py +++ b/routingfilter/routing.py @@ -64,7 +64,7 @@ def match(self, event: dict, type_: str = "streams", tag_field_name: str = "tags # check stream if type_ == "streams": stream = self.streams - elif type_ == "customer": + elif type_ == "customers": stream = self.customer else: self.logger.error(f"Error during matching. Invalid Stream: {type_}") diff --git a/setup.py b/setup.py index 571cf12..32a087b 100644 --- a/setup.py +++ b/setup.py @@ -5,7 +5,7 @@ setup( name="routingfilter", - version="2.2.0", + version="2.2.1", packages=find_packages(include=["routingfilter", "routingfilter.*"]), include_package_data=True, install_requires=["IPy~=1.1", "macaddress~=2.0.2"],