File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -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