@@ -30,12 +30,12 @@ class BatchAddRequestsResult(TypedDict):
30
30
"""Result of the batch add requests operation.
31
31
32
32
Args:
33
- processed_requests : List of successfully added requests.
34
- unprocessed_requests : List of requests that failed to be added.
33
+ processedRequests : List of successfully added requests.
34
+ unprocessedRequests : List of requests that failed to be added.
35
35
"""
36
36
37
- processed_requests : list [dict ]
38
- unprocessed_requests : list [dict ]
37
+ processedRequests : list [dict ]
38
+ unprocessedRequests : list [dict ]
39
39
40
40
41
41
@dataclass
@@ -351,8 +351,8 @@ def batch_add_requests(
351
351
unprocessed_requests .extend (response_parsed .get ('unprocessedRequests' , []))
352
352
353
353
return {
354
- 'processed_requests ' : processed_requests ,
355
- 'unprocessed_requests ' : unprocessed_requests ,
354
+ 'processedRequests ' : processed_requests ,
355
+ 'unprocessedRequests ' : unprocessed_requests ,
356
356
}
357
357
358
358
def batch_delete_requests (self : RequestQueueClient , requests : list [dict ]) -> dict :
@@ -685,8 +685,8 @@ async def _batch_add_requests_worker(
685
685
queue .task_done ()
686
686
687
687
return {
688
- 'processed_requests ' : processed_requests ,
689
- 'unprocessed_requests ' : unprocessed_requests ,
688
+ 'processedRequests ' : processed_requests ,
689
+ 'unprocessedRequests ' : unprocessed_requests ,
690
690
}
691
691
692
692
async def batch_add_requests (
@@ -756,12 +756,12 @@ async def batch_add_requests(
756
756
unprocessed_requests = []
757
757
758
758
for result in results :
759
- processed_requests .extend (result ['processed_requests ' ])
760
- unprocessed_requests .extend (result ['unprocessed_requests ' ])
759
+ processed_requests .extend (result ['processedRequests ' ])
760
+ unprocessed_requests .extend (result ['unprocessedRequests ' ])
761
761
762
762
return {
763
- 'processed_requests ' : processed_requests ,
764
- 'unprocessed_requests ' : unprocessed_requests ,
763
+ 'processedRequests ' : processed_requests ,
764
+ 'unprocessedRequests ' : unprocessed_requests ,
765
765
}
766
766
767
767
async def batch_delete_requests (self : RequestQueueClientAsync , requests : list [dict ]) -> dict :
0 commit comments