Skip to content

Commit 7f8919a

Browse files
committed
formatting
Signed-off-by: Gabriele Santomaggio <[email protected]>
1 parent 683bb12 commit 7f8919a

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

Makefile

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ rabbitmq-server-stop:
99

1010
format:
1111
poetry run isort --skip rabbitmq_amqp_python_client/qpid --skip .venv .
12+
poetry run mypy --exclude=rabbitmq_amqp_python_client/qpid .
1213
poetry run black rabbitmq_amqp_python_client/
1314
poetry run black tests/
1415
poetry run flake8 --exclude=venv,.venv,local_tests,docs/examples,rabbitmq_amqp_python_client/qpid --max-line-length=120 --ignore=E203,W503

rabbitmq_amqp_python_client/entities.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -285,7 +285,8 @@ def __init__(
285285
if filter_options is not None and filter_options.match_unfiltered:
286286
self._filter_match_unfiltered(filter_options.match_unfiltered)
287287

288-
self._filter_message_properties(filter_options.message_properties)
288+
if filter_options is not None and filter_options.message_properties is not None:
289+
self._filter_message_properties(filter_options.message_properties)
289290

290291
def _offset(self, offset_specification: Union[OffsetSpecification, int]) -> None:
291292
"""
@@ -327,7 +328,9 @@ def _filter_match_unfiltered(self, filter_match_unfiltered: bool) -> None:
327328
symbol(STREAM_FILTER_MATCH_UNFILTERED), filter_match_unfiltered
328329
)
329330

330-
def _filter_message_properties(self, message_properties: MessageProperties) -> None:
331+
def _filter_message_properties(
332+
self, message_properties: Optional[MessageProperties]
333+
) -> None:
331334
"""
332335
Set application properties for filtering.
333336

0 commit comments

Comments
 (0)