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

use crate::serde::duration;
use serde::{Deserialize, Serialize};
use std::time::Duration;

pub mod blender;
pub mod glambda;
pub mod wasm;

#[derive(Serialize, Deserialize, Debug, Clone)]
pub struct TaskDef<Options: TaskDefOptions> {
    #[serde(rename = "type")]
    task_type: String,
    compute_on: ComputeOn,
    name: String,
    #[serde(with = "duration")]
    timeout: Duration,
    #[serde(with = "duration")]
    subtask_timeout: Duration,
    // GNT/h
    bid: f64,
    resources: Vec<String>,
    concent_enabled: bool,
    #[serde(default)]
    subtasks_count: u64,
    options: Options,
}

pub trait TaskDefOptions {
    const TASK_TYPE: &'static str;
}

#[derive(Serialize, Deserialize, Debug, Clone)]
#[serde(rename_all = "lowercase")]
pub enum ComputeOn {
    GPU,
    CPU,
}