diff --git a/es_relval_log.py b/es_relval_log.py index 8ebe65a2899..c3d66640744 100755 --- a/es_relval_log.py +++ b/es_relval_log.py @@ -90,7 +90,9 @@ def es_parse_jobreport(payload, logFile): def es_parse_log(logFile): stamp = "%s-es" % logFile - if exists(stamp): return + if exists(stamp): + print("Adready process: ",logFile) + return t = os.path.getmtime(logFile) timestp = int(t * 1000) payload = {} @@ -213,6 +215,7 @@ def es_parse_log(logFile): send_payload("ib-dataset-" + week, "relvals-dataset", idx, json.dumps(dataset)) ref = open(stamp, "w") ref.close() + print("Done processing :",logFile) if __name__ == "__main__":