Method add_request

src/crawlee/storages/_request_queue.py:178–198

(
        self,
        request: str | Request,
        *,
        forefront: bool = False,
    )

    @override
    async def add_request(
        self,
        request: str | Request,
        *,
        forefront: bool = False,
    ) -> ProcessedRequest | None:
        request = self._transform_request(request)
        # Route through `_process_batch` so a single add retries unprocessed requests just like a batched one.
        response = await self._process_batch([request], base_retry_wait=timedelta(seconds=1), forefront=forefront)

        if response.processed_requests:
            return response.processed_requests[0]

        # `_process_batch` already warns about requests left unprocessed after retries; only an empty response
        # (neither processed nor unprocessed) is unexpected here.
        if not response.unprocessed_requests:
            logger.warning(
                f'Request {request.url} was not processed by storage client '
                f'"{self._client.__class__.__name__}" (received an empty response).'
            )
        return None

    @override
    async def add_requests(