Skip to content

Commit 0c25039

Browse files
Record completed jobs only after storing into database
1 parent afd84b4 commit 0c25039

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

src/server/routes/agent.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -195,12 +195,6 @@ impl RecordProgressThread {
195195
let start = std::time::Instant::now();
196196

197197
if let Some(ex) = Experiment::get(&db, &result.experiment_name).unwrap() {
198-
metrics.record_completed_jobs(
199-
&worker_name,
200-
&ex.name,
201-
result.data.results.len() as i64,
202-
);
203-
204198
let db = DatabaseDB::new(&db);
205199
if let Err(e) = db.store(&ex, &result.data, EncodingType::Plain) {
206200
// Failing to record a result is basically fine -- this
@@ -209,6 +203,12 @@ impl RecordProgressThread {
209203
crate::utils::report_failure(&e);
210204
}
211205

206+
metrics.record_completed_jobs(
207+
&worker_name,
208+
&ex.name,
209+
result.data.results.len() as i64,
210+
);
211+
212212
if let Err(e) = db.clear_stale_records() {
213213
// Not a hard failure. We can continue even if we failed
214214
// to clear records from already completed runs...

0 commit comments

Comments
 (0)