We add the filter error_id in commit: 1c154d888fab1fce4623663b4a88b9a1630171c2,
we don't need it now, so delete the filter error_id,
add the new_error_id log for statistical.
Signed-off-by: Cao Xueliang <caoxl78320(a)163.com>
---
src/extract-stats/stats_worker.cr | 17 ++++++-----------
1 file changed, 6 insertions(+), 11 deletions(-)
diff --git a/src/extract-stats/stats_worker.cr b/src/extract-stats/stats_worker.cr
index 01bae21..836d1f8 100644
--- a/src/extract-stats/stats_worker.cr
+++ b/src/extract-stats/stats_worker.cr
@@ -82,25 +82,20 @@ class StatsWorker
}
)
- error_id = select_error_id(check_new_error_ids(error_ids, job_id))
- if error_id
+ new_error_ids = check_new_error_ids(error_ids, job_id)
+ unless new_error_ids.empty?
+ sample_error_id = new_error_ids.sample
STDOUT.puts "send a delimiter task: job_id is #{job_id}"
- @tq.add_task(DELIMITER_TASK_QUEUE, JSON.parse({"error_id" => error_id,
+ @tq.add_task(DELIMITER_TASK_QUEUE, JSON.parse({"error_id" => sample_error_id,
"job_id" => job_id,
"lab" => LAB}.to_json))
+ msg = %({"job_id": "#{job_id}", "new_error_id": "#{sample_error_id}"})
+ system "echo '#{msg}'"
end
msg = %({"job_id": "#{job_id}", "job_state": "extract_finished"})
system "echo '#{msg}'"
end
- def select_error_id(new_error_ids : Array)
- new_error_ids.each do |error_id|
- return error_id if /(cpp|c|h):(warning|error)/i =~ error_id
- end
-
- return nil
- end
-
def check_new_error_ids(error_ids : Array, job_id : String)
new_error_ids = [] of String
error_ids.each do |error_id|
--
2.23.0