diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/db/models/job.rs | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/db/models/job.rs b/src/db/models/job.rs index 12fba7b..8240bd8 100644 --- a/src/db/models/job.rs +++ b/src/db/models/job.rs @@ -45,7 +45,7 @@ impl Job { container: &ContainerHash, script: &Script, log: &str, - ) -> Result<()> { + ) -> Result<Job> { let new_job = NewJob { uuid: job_uuid, submit_id: submit.id, @@ -61,9 +61,12 @@ impl Job { diesel::insert_into(jobs::table) .values(&new_job) .on_conflict_do_nothing() - .execute(database_connection) + .execute(database_connection)?; + + dsl::jobs + .filter(uuid.eq(job_uuid)) + .first::<Job>(database_connection) .map_err(Error::from) - .map(|_| ()) } } |