Skip to content

Commit 2fa7799

Browse files
committed
fix: type hints and dict assignment
1 parent f1f4545 commit 2fa7799

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

.pre-commit-config.yaml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ repos:
66
hooks:
77
- id: check-ast
88
- id: trailing-whitespace
9+
exclude: 'README.md'
910
- id: check-toml
1011
- id: end-of-file-fixer
1112

taskiq_aio_pika/broker.py

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -228,21 +228,20 @@ async def kick(self, message: BrokerMessage) -> None:
228228
if self.write_channel is None:
229229
raise ValueError("Please run startup before kicking.")
230230

231-
message_base_params: dict[str, Any] = {
231+
message_base_params: Dict[str, Any] = {
232232
"body": message.message,
233233
"headers": {
234234
"task_id": message.task_id,
235235
"task_name": message.task_name,
236236
**message.labels,
237237
},
238238
"delivery_mode": DeliveryMode.PERSISTENT,
239+
"priority": parse_val(
240+
int,
241+
message.labels.get("priority"),
242+
),
239243
}
240244

241-
message_base_params["priority"] = parse_val(
242-
int,
243-
message.labels.get("priority"),
244-
)
245-
246245
delay: Optional[int] = parse_val(int, message.labels.get("delay"))
247246
rmq_message: Message = Message(**message_base_params)
248247

0 commit comments

Comments
 (0)