File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
nodestream/cli/operations Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -123,7 +123,6 @@ def create_progress_reporter(
123
123
) -> PipelineProgressReporter :
124
124
indicator = self .get_progress_indicator (command , pipeline_name )
125
125
return PipelineProgressReporter (
126
- logger = indicator .logger ,
127
126
reporting_frequency = int (command .option ("reporting-frequency" )),
128
127
callback = indicator .progress_callback ,
129
128
on_start_callback = indicator .on_start ,
@@ -136,7 +135,6 @@ class ProgressIndicator:
136
135
def __init__ (self , command : NodestreamCommand , pipeline_name : str ) -> None :
137
136
self .command = command
138
137
self .pipeline_name = pipeline_name
139
- self .logger = getLogger ()
140
138
141
139
def on_start (self ):
142
140
pass
@@ -185,6 +183,7 @@ def on_fatal_error(self, exception: Exception):
185
183
class JsonProgressIndicator (ProgressIndicator ):
186
184
def __init__ (self , command : NodestreamCommand , pipeline_name : str ) -> None :
187
185
super ().__init__ (command , pipeline_name )
186
+ self .logger = getLogger ()
188
187
self .exception = None
189
188
190
189
def on_start (self ):
You can’t perform that action at this time.
0 commit comments