fix: use float to parse delay

Author: danfimov

taskiq_aio_pika/broker.py

@@ -367,7 +367,7 @@ async def kick(self, message: BrokerMessage) -> None:
             delivery_mode=DeliveryMode.PERSISTENT,
             priority=priority,
         )
-        delay = parse_val(int, message.labels.get("delay"))
+        delay = parse_val(float, message.labels.get("delay"))
 
         if len(self._task_queues) == 1:
             routing_key_name = (

tests/test_routing.py

@@ -181,7 +181,7 @@ async def test_when_queue_bind_with_pattern_and_exchange_type_topic__when_messag
         ), "Message was not routed to queue, but should be by specific name"
         await received_message_2.ack()
 
-    async def test_when_exchange_fanaout__when_message_published_in_all_queues(
+    async def test_when_exchange_fanout__when_message_published_in_all_queues(
         self,
         amqp_url: str,
         test_channel: Channel,