From c5260982cccee7a1c160beb5e73d1840e2e77096 Mon Sep 17 00:00:00 2001 From: Artur Shiriev Date: Wed, 4 Nov 2026 17:27:29 +0300 Subject: [PATCH] Fix fetch limit bind parameter type inference --- faststream_outbox/client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/faststream_outbox/client.py b/faststream_outbox/client.py index 37a0b05..bff2b14 100644 --- a/faststream_outbox/client.py +++ b/faststream_outbox/client.py @@ -215,7 +215,7 @@ def _build_fetch_stmt(outbox: "Table") -> "Update": sorting the whole backlog. See ADR 0003 for why the query has this shape. """ t = outbox - limit = bindparam("limit", type_=Integer) + limit = bindparam("limit", type_=Integer()) lease_cutoff = func.now() - _seconds("lease_ttl") queue_array = ARRAY(String) queue_name = func.unnest(cast(bindparam("queues", type_=queue_array), queue_array)).label("name")