File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -157,7 +157,9 @@ def __next__(self):
157
157
raise StopIteration from exc
158
158
if isinstance (data , Exception ):
159
159
raise data from None
160
- self ._changes_iter = iter (data )
160
+ self ._changes_iter = iter (
161
+ (ChangesResultItem .from_dict (item ) for item in data )
162
+ )
161
163
self ._buffer .task_done ()
162
164
163
165
def _request_callback (self ):
@@ -178,9 +180,7 @@ def _request_callback(self):
178
180
self ._buffer .join ()
179
181
if self ._stop .is_set ():
180
182
raise StopIteration
181
- self ._buffer .put (
182
- [ChangesResultItem .from_dict (item ) for item in results ]
183
- )
183
+ self ._buffer .put (results )
184
184
except Exception as e :
185
185
if type (e ) is not StopIteration :
186
186
self .logger .debug (f'Exception getting changes { e } ' )
You can’t perform that action at this time.
0 commit comments