Struct QueuedJob

pub struct QueuedJob {

    pub workspace_id: Option<String>,
    pub id: Uuid,
    pub parent_job: Option<Uuid>,
    pub created_by: Option<String>,
    pub created_at: Option<String>,
    pub started_at: Option<String>,
    pub scheduled_for: Option<String>,
    pub running: bool,
    pub script_path: Option<String>,
    pub script_hash: Option<String>,
    pub args: Option<HashMap<String, Value>>,
    pub logs: Option<String>,
    pub raw_code: Option<String>,
    pub canceled: bool,
    pub canceled_by: Option<String>,
    pub canceled_reason: Option<String>,
    pub last_ping: Option<String>,
    pub job_kind: JobKind,
    pub schedule_path: Option<String>,
    pub permissioned_as: String,
    pub flow_status: Option<Box<FlowStatus>>,
    pub workflow_as_code_status: Option<Box<WorkflowStatus>>,
    pub raw_flow: Option<Box<FlowValue>>,
    pub is_flow_step: bool,
    pub language: Option<ScriptLang>,
    pub email: String,
    pub visible_to_owner: bool,
    pub mem_peak: Option<i32>,
    pub tag: String,
    pub priority: Option<i32>,
    pub self_wait_time_ms: Option<f64>,
    pub aggregate_wait_time_ms: Option<f64>,
    pub suspend: Option<f64>,
    pub preprocessed: Option<bool>,
    pub worker: Option<String>,
}

Fields

workspace_id: Option<String>

id: Uuid

parent_job: Option<Uuid>

created_by: Option<String>

created_at: Option<String>

started_at: Option<String>

scheduled_for: Option<String>

running: bool

script_path: Option<String>

script_hash: Option<String>

args: Option<HashMap<String, Value>>

logs: Option<String>

raw_code: Option<String>

canceled: bool

canceled_by: Option<String>

canceled_reason: Option<String>

last_ping: Option<String>

job_kind: JobKind

schedule_path: Option<String>

permissioned_as: String

The user (u/userfoo) or group (g/groupfoo) whom the execution of this script will be permissioned_as and by extension its DT_TOKEN.

flow_status: Option<Box<FlowStatus>>

workflow_as_code_status: Option<Box<WorkflowStatus>>

raw_flow: Option<Box<FlowValue>>

is_flow_step: bool

language: Option<ScriptLang>

email: String

visible_to_owner: bool

mem_peak: Option<i32>

tag: String

priority: Option<i32>

self_wait_time_ms: Option<f64>

aggregate_wait_time_ms: Option<f64>

suspend: Option<f64>

preprocessed: Option<bool>

worker: Option<String>

Implementations

impl QueuedJob

pub fn new( id: Uuid, running: bool, canceled: bool, job_kind: JobKind, permissioned_as: String, is_flow_step: bool, email: String, visible_to_owner: bool, tag: String, ) -> QueuedJob

Trait Implementations

impl Clone for QueuedJob

fn clone(&self) -> QueuedJob

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for QueuedJob

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for QueuedJob

fn default() -> QueuedJob

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for QueuedJob

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for QueuedJob

fn eq(&self, other: &QueuedJob) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for QueuedJob

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for QueuedJob