Keep only relevant log

Author: Pijukatel

src/apify/storage_clients/_apify/_request_queue_client.py

@@ -255,7 +255,11 @@ async def add_batch_of_requests(
 
             else:
                 new_requests.append(request)
-        logger.info(f'Add new requests: {len(new_requests)}, already present requests: {len(already_present_requests)}')
+
+        logger.debug(
+            f'Adding new requests: {len(new_requests)}, '
+            f'skipping already present requests: {len(already_present_requests)}'
+        )
         if new_requests:
             # Prepare requests for API by converting to dictionaries.
             requests_dict = [
@@ -267,7 +271,6 @@ async def add_batch_of_requests(
             ]
 
             # Send requests to API.
-            logger.info(f'self._api_client.batch_add_requests, {len(new_requests)=}')
             response = await self._api_client.batch_add_requests(requests=requests_dict, forefront=forefront)
             # Add new requests to the cache.
             for processed_request_raw in response['processedRequests']:
@@ -303,7 +306,6 @@ async def get_request(self, request_id: str) -> Request | None:
         Returns:
             The request or None if not found.
         """
-        logger.info(f'self._api_client.get_request, {request_id=}')
         response = await self._api_client.get_request(request_id)
 
         if response is None:
@@ -555,7 +557,6 @@ async def _update_request(
         Returns:
             The updated request
         """
-        logger.info(f'self._api_client.update_request, {len(request.id)=}')
         response = await self._api_client.update_request(
             request=request.model_dump(by_alias=True),
             forefront=forefront,
@@ -607,7 +608,6 @@ async def _list_head(
         lock_time = lock_time or self._DEFAULT_LOCK_TIME
         lock_secs = int(lock_time.total_seconds())
 
-        logger.info('self._api_client.list_and_lock_head')
         response = await self._api_client.list_and_lock_head(
             lock_secs=lock_secs,
             limit=limit,
@@ -689,7 +689,6 @@ async def _prolong_request_lock(
         Returns:
             A response containing the time at which the lock will expire.
         """
-        logger.info(f'self._api_client.prolong_request_lock, {request_id=}')
         response = await self._api_client.prolong_request_lock(
             request_id=request_id,
             forefront=forefront,
@@ -721,7 +720,6 @@ async def _delete_request_lock(
             forefront: Whether to put the request in the beginning or the end of the queue after the lock is deleted.
         """
         try:
-            logger.info(f'self._api_client.delete_request_lock, {request_id=}')
             await self._api_client.delete_request_lock(
                 request_id=request_id,
                 forefront=forefront,