start span for evaluations in consumer

This commit is contained in:
Daiderd Jordan 2020-05-21 21:14:25 +02:00
parent 9120d16bd7
commit 910330c28d
No known key found for this signature in database
GPG key ID: D02435D05B810C96

View file

@ -80,6 +80,9 @@ impl<E: stats::SysEvents + 'static> worker::SimpleWorker for EvaluationWorker<E>
} }
fn consumer(&mut self, job: &evaluationjob::EvaluationJob) -> worker::Actions { fn consumer(&mut self, job: &evaluationjob::EvaluationJob) -> worker::Actions {
let span = debug_span!("job", pr = ?job.pr.number);
let _enter = span.enter();
let mut vending_machine = self let mut vending_machine = self
.github_vend .github_vend
.write() .write()
@ -249,9 +252,6 @@ impl<'a, E: stats::SysEvents + 'static> OneEval<'a, E> {
// FIXME: remove with rust/cargo update // FIXME: remove with rust/cargo update
#[allow(clippy::cognitive_complexity)] #[allow(clippy::cognitive_complexity)]
fn evaluate_job(&mut self) -> Result<worker::Actions, EvalWorkerError> { fn evaluate_job(&mut self) -> Result<worker::Actions, EvalWorkerError> {
let span = debug_span!("job", pr = ?self.job.pr.number);
let _enter = span.enter();
let job = self.job; let job = self.job;
let repo = self let repo = self
.client_app .client_app