We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7443c6c commit 8031a82Copy full SHA for 8031a82
src/db.rs
@@ -225,7 +225,10 @@ pub async fn schedule_job(
225
anyhow::bail!("Job {} does not exist in the current job list.", job_name);
226
}
227
228
- if let Err(_) = get_job_by_name_and_scheduled_at(db, job_name, &when).await {
+ if get_job_by_name_and_scheduled_at(db, job_name, &when)
229
+ .await
230
+ .is_err()
231
+ {
232
// mean there's no job already in the db with that name and scheduled_at
233
insert_job(db, job_name, &when, &job_metadata).await?;
234
0 commit comments