Correct rescheduling of ExternalStatisticsTask (#59076)
This commit is contained in:
parent
c3fc19915e
commit
491e62792b
1 changed files with 1 additions and 1 deletions
|
@ -798,7 +798,7 @@ class Recorder(threading.Thread):
|
||||||
if statistics.add_external_statistics(self, metadata, stats):
|
if statistics.add_external_statistics(self, metadata, stats):
|
||||||
return
|
return
|
||||||
# Schedule a new statistics task if this one didn't finish
|
# Schedule a new statistics task if this one didn't finish
|
||||||
self.queue.put(StatisticsTask(metadata, stats))
|
self.queue.put(ExternalStatisticsTask(metadata, stats))
|
||||||
|
|
||||||
def _process_one_event(self, event):
|
def _process_one_event(self, event):
|
||||||
"""Process one event."""
|
"""Process one event."""
|
||||||
|
|
Loading…
Add table
Reference in a new issue