1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
//
// Copyright (c) 2020-2022 science+computing ag and other contributors
//
// This program and the accompanying materials are made
// available under the terms of the Eclipse Public License 2.0
// which is available at https://www.eclipse.org/legal/epl-2.0/
//
// SPDX-License-Identifier: EPL-2.0
//
use anyhow::Error;
use anyhow::Context;
use anyhow::Result;
use diesel::prelude::*;
use diesel::PgConnection;
use log::trace;
use crate::db::models::{Endpoint, Image, Package, Submit};
use crate::package::Script;
use crate::schema::jobs;
use crate::schema::jobs::*;
use crate::util::docker::ContainerHash;
#[derive(Debug, Eq, PartialEq, Identifiable, Queryable, Associations)]
#[belongs_to(Submit)]
#[belongs_to(Endpoint)]
#[belongs_to(Package)]
#[belongs_to(Image)]
#[table_name = "jobs"]
pub struct Job {
pub id: i32,
pub submit_id: i32,
pub endpoint_id: i32,
pub package_id: i32,
pub image_id: i32,
pub container_hash: String,
pub script_text: String,
pub log_text: String,
pub uuid: ::uuid::Uuid,
}
#[derive(Debug, Insertable)]
#[table_name = "jobs"]
struct NewJob<'a> {
pub submit_id: i32,
pub endpoint_id: i32,
pub package_id: i32,
pub image_id: i32,
pub container_hash: &'a str,
pub script_text: String,
pub log_text: String,
pub uuid: &'a ::uuid::Uuid,
}
impl Job {
#[allow(clippy::too_many_arguments)]
pub fn create(
database_connection: &PgConnection,
job_uuid: &::uuid::Uuid,
submit: &Submit,
endpoint: &Endpoint,
package: &Package,
image: &Image,
container: &ContainerHash,
script: &Script,
log: &str,
) -> Result<Job> {
let new_job = NewJob {
uuid: job_uuid,
submit_id: submit.id,
endpoint_id: endpoint.id,
package_id: package.id,
image_id: image.id,
container_hash: container.as_ref(),
script_text: script.as_ref().replace('\0', ""),
log_text: log.replace('\0', ""),
};
trace!("Creating Job in database: {:?}", new_job);
let query = diesel::insert_into(jobs::table)
.values(&new_job)
.on_conflict_do_nothing();
log::trace!("Query = {}", diesel::debug_query::<diesel::pg::Pg, _>(&query));
database_connection.transaction::<_, Error, _>(|| {
query
.execute(database_connection)
.context("Creating job in database")?;
dsl::jobs
.filter(uuid.eq(job_uuid))
.first::<Job>(database_connection)
.with_context(|| format!("Finding created job in database: {}", job_uuid))
.map_err(Error::from)
})
}
pub fn env(&self, database_connection: &PgConnection) -> Result<Vec<crate::db::models::EnvVar>> {
use crate::schema;
schema::job_envs::table
.inner_join(schema::envvars::table)
.filter(schema::job_envs::job_id.eq(self.id))
.select(schema::envvars::all_columns)
.load::<crate::db::models::EnvVar>(database_connection)
.map_err(Error::from)
}
}
|
