chore: track uv.lock for reproducible installs

.gitignore

@@ -116,7 +116,6 @@ logs/
 
 # UV
 .uv/
-uv.lock
 
 # Vibe coding
 .vibe/

src/fireflyframework_genai/exposure/queues/kafka.py

@@ -138,7 +138,8 @@ async def publish(self, message: QueueMessage) -> None:
         """Publish *message* to the configured Kafka topic."""
         if self._producer is None:
             await self.start()
-        await self._producer.send_and_wait(
+        producer: Any = self._producer
+        await producer.send_and_wait(
             self._topic,
             value=message.body.encode("utf-8"),
             headers=[(k, v.encode("utf-8")) for k, v in message.headers.items()] or None,

src/fireflyframework_genai/exposure/queues/rabbitmq.py

@@ -139,11 +139,8 @@ async def publish(self, message: QueueMessage) -> None:
         if self._channel is None:
             await self.start()
 
-        exchange = (
-            await self._channel.get_exchange(self._exchange_name)
-            if self._exchange_name
-            else self._channel.default_exchange
-        )
+        channel: Any = self._channel
+        exchange = await channel.get_exchange(self._exchange_name) if self._exchange_name else channel.default_exchange
         amqp_message = aio_pika.Message(
             body=message.body.encode("utf-8"),
             headers=cast("dict[str, Any]", message.headers) or None,

src/fireflyframework_genai/exposure/queues/redis.py

@@ -147,7 +147,8 @@ async def publish(self, message: QueueMessage) -> None:
         """Publish *message* to the configured Redis channel."""
         if self._client is None:
             await self.start()
-        await self._client.publish(self._channel, message.body.encode("utf-8"))
+        client: Any = self._client
+        await client.publish(self._channel, message.body.encode("utf-8"))
 
     async def stop(self) -> None:
         """Close the Redis connection."""