fix

Mantisus · Mantisus · commit cd64f6f99749 · 2026-04-08T19:52:34.000Z
diff --git a/src/crawlee/storage_clients/_sql/_request_queue_client.py b/src/crawlee/storage_clients/_sql/_request_queue_client.py
@@ -431,6 +431,8 @@ async def fetch_next_request(self) -> Request | None:
             .limit(self._MAX_BATCH_FETCH_SIZE)
         )
 
+        requests_db = None
+
         async with self.get_session(with_simple_commit=True) as session:
             # We use the `skip_locked` database mechanism to prevent the 'interception' of requests by another client
             if dialect in {'postgresql', 'mysql', 'mariadb'}:

Original file line number	Diff line number	Diff line change
`@@ -431,6 +431,8 @@ async def fetch_next_request(self) -> Request \| None:`
`431`	`431`	`.limit(self._MAX_BATCH_FETCH_SIZE)`
`432`	`432`	`)`
`433`	`433`
	`434`	`+ requests_db = None`
	`435`	`+`
`434`	`436`	`async with self.get_session(with_simple_commit=True) as session:`
`435`	`437`	# We use the `skip_locked` database mechanism to prevent the 'interception' of requests by another client
`436`	`438`	`if dialect in {'postgresql', 'mysql', 'mariadb'}:`