@@ -1571,31 +1571,31 @@ def __init__(
1571
1571
async def initialize (self ) -> "ClusterPipeline" :
1572
1572
if self .cluster_client ._initialize :
1573
1573
await self .cluster_client .initialize ()
1574
- self ._execution_strategy ._command_stack = []
1574
+ self ._execution_strategy ._command_queue = []
1575
1575
return self
1576
1576
1577
1577
async def __aenter__ (self ) -> "ClusterPipeline" :
1578
1578
return await self .initialize ()
1579
1579
1580
1580
async def __aexit__ (self , exc_type : None , exc_value : None , traceback : None ) -> None :
1581
- self ._execution_strategy ._command_stack = []
1581
+ self ._execution_strategy ._command_queue = []
1582
1582
1583
1583
def __await__ (self ) -> Generator [Any , None , "ClusterPipeline" ]:
1584
1584
return self .initialize ().__await__ ()
1585
1585
1586
1586
def __enter__ (self ) -> "ClusterPipeline" :
1587
- self ._execution_strategy ._command_stack = []
1587
+ self ._execution_strategy ._command_queue = []
1588
1588
return self
1589
1589
1590
1590
def __exit__ (self , exc_type : None , exc_value : None , traceback : None ) -> None :
1591
- self ._execution_strategy ._command_stack = []
1591
+ self ._execution_strategy ._command_queue = []
1592
1592
1593
1593
def __bool__ (self ) -> bool :
1594
1594
"Pipeline instances should always evaluate to True on Python 3+"
1595
1595
return True
1596
1596
1597
1597
def __len__ (self ) -> int :
1598
- return len (self ._execution_strategy ._command_stack )
1598
+ return len (self ._execution_strategy ._command_queue )
1599
1599
1600
1600
def execute_command (
1601
1601
self , * args : Union [KeyT , EncodableT ], ** kwargs : Any
@@ -1931,7 +1931,7 @@ async def execute(
1931
1931
# All other errors should be raised.
1932
1932
raise e
1933
1933
finally :
1934
- self ._command_stack = []
1934
+ self ._command_queue = []
1935
1935
1936
1936
async def _execute (
1937
1937
self ,
0 commit comments