Commit ae800389 authored by Doak, Peter W's avatar Doak, Peter W
Browse files

more work needed to actually remove offset files

parent b4ddac1a
......@@ -57,7 +57,7 @@ def read_output_influx(log):
watch_log = open(os.path.join(ld,"{}.log".format(job_tag)),'w')
watch_log.write("Watching {}\n".format(log))
watch_start = ('start' in config)
header_element_found = {x:False for x in config['header']}
while True:
offset_file = os.path.join(ld,"{}.off".format(job_tag))
influx_lines = []
......@@ -203,7 +203,9 @@ if __name__ == '__main__':
if watch_idlers[idle_log] > config["idle_count"]:
del watch_idlers[idle_log]
log_2_process[log].terminate()
del log_2_process[log]
del log_2_process[idle_log]
#os.remove("{}.off".format(idle_log))
#can't do this unless we can get the reader to tell us what the log_tag is
#delete offset file here
print "sleeping..."
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment