Skip to content

Commit af4f6a6

Browse files
committed
started_retryable_write should only belong to bulk class and not run
1 parent 89e8b3d commit af4f6a6

File tree

3 files changed

+0
-3
lines changed

3 files changed

+0
-3
lines changed

pymongo/asynchronous/bulk.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -525,7 +525,6 @@ async def _execute_command(
525525
while run:
526526
self.is_retryable = run.is_retryable
527527
self.retrying = run.retrying
528-
self.started_retryable_write = run.started_retryable_write
529528
if not self.retrying:
530529
self.next_run = next(generator, None)
531530
if self.next_run is None:

pymongo/bulk_shared.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,6 @@ def __init__(self, op_type: int) -> None:
5252
self.idx_offset: int = 0
5353
self.is_retryable = True
5454
self.retrying = False
55-
self.started_retryable_write = False
5655

5756
def index(self, idx: int) -> int:
5857
"""Get the original index of an operation in this run.

pymongo/synchronous/bulk.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -525,7 +525,6 @@ def _execute_command(
525525
while run:
526526
self.is_retryable = run.is_retryable
527527
self.retrying = run.retrying
528-
self.started_retryable_write = run.started_retryable_write
529528
if not self.retrying:
530529
self.next_run = next(generator, None)
531530
if self.next_run is None:

0 commit comments

Comments
 (0)