File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -2182,7 +2182,7 @@ def __init__(
2182
2182
self ._execution_strategy : ExecutionStrategy = (
2183
2183
PipelineStrategy (self ) if not transaction else TransactionStrategy (self )
2184
2184
)
2185
- self .command_stack = self ._execution_strategy .command_queue
2185
+ self .command_stack = self ._execution_strategy ._command_queue
2186
2186
2187
2187
def __repr__ (self ):
2188
2188
""" """
@@ -2603,25 +2603,25 @@ def __init__(
2603
2603
self ,
2604
2604
pipe : ClusterPipeline ,
2605
2605
):
2606
- self .command_queue : List [PipelineCommand ] = []
2606
+ self ._command_queue : List [PipelineCommand ] = []
2607
2607
self ._pipe = pipe
2608
2608
self ._nodes_manager = self ._pipe .nodes_manager
2609
2609
2610
2610
@property
2611
2611
def command_queue (self ):
2612
- return self .command_queue
2612
+ return self ._command_queue
2613
2613
2614
2614
@command_queue .setter
2615
2615
def command_queue (self , queue : List [PipelineCommand ]):
2616
- self .command_queue = queue
2616
+ self ._command_queue = queue
2617
2617
2618
2618
@abstractmethod
2619
2619
def execute_command (self , * args , ** kwargs ):
2620
2620
pass
2621
2621
2622
2622
def pipeline_execute_command (self , * args , ** options ):
2623
- self .command_queue .append (
2624
- PipelineCommand (args , options , len (self .command_queue ))
2623
+ self ._command_queue .append (
2624
+ PipelineCommand (args , options , len (self ._command_queue ))
2625
2625
)
2626
2626
return self ._pipe
2627
2627
You can’t perform that action at this time.
0 commit comments