mirror of https://github.com/D4-project/d4-core
chg: [filerwatcher] fix double queue logging for compressed files
parent
36a771ea2d
commit
a6d5a3d22c
|
@ -54,8 +54,8 @@ class TypeHandler(MetaTypesDefault):
|
||||||
shutil.copyfileobj(f_in, f_out)
|
shutil.copyfileobj(f_in, f_out)
|
||||||
os.remove(path)
|
os.remove(path)
|
||||||
self.send_to_analyzers(compressed_filename)
|
self.send_to_analyzers(compressed_filename)
|
||||||
# Send data to Analyzer
|
else:
|
||||||
self.send_to_analyzers(path)
|
self.send_to_analyzers(path)
|
||||||
|
|
||||||
def reconstruct_data(self, data):
|
def reconstruct_data(self, data):
|
||||||
# save data in buffer
|
# save data in buffer
|
||||||
|
|
Loading…
Reference in New Issue