Struct ExportableQueuedJob 

pub struct ExportableQueuedJob {

    pub id: Uuid,
    pub parent_job: Option<Uuid>,
    pub created_by: String,
    pub created_at: String,
    pub started_at: Option<String>,
    pub scheduled_for: Option<String>,
    pub script_path: Option<String>,
    pub script_hash: Option<String>,
    pub args: Option<Value>,
    pub logs: Option<String>,
    pub raw_code: Option<String>,
    pub raw_lock: Option<String>,
    pub canceled_by: Option<String>,
    pub canceled_reason: Option<String>,
    pub job_kind: JobKind,
    pub trigger: Option<String>,
    pub trigger_kind: Option<TriggerKind>,
    pub permissioned_as: String,
    pub permissioned_as_email: Option<String>,
    pub flow_status: Option<Value>,
    pub workflow_as_code_status: Option<Value>,
    pub raw_flow: Option<Value>,
    pub is_flow_step: Option<bool>,
    pub language: Option<ScriptLang>,
    pub email: String,
    pub visible_to_owner: bool,
    pub mem_peak: Option<i32>,
    pub tag: Option<String>,
    pub priority: Option<i32>,
    pub labels: Option<Vec<String>>,
    pub same_worker: Option<bool>,
    pub flow_step_id: Option<String>,
    pub flow_innermost_root_job: Option<Uuid>,
    pub concurrent_limit: Option<i32>,
    pub concurrency_time_window_s: Option<i32>,
    pub timeout: Option<i32>,
    pub cache_ttl: Option<i32>,
    pub self_wait_time_ms: Option<i32>,
    pub aggregate_wait_time_ms: Option<i32>,
    pub preprocessed: Option<bool>,
    pub suspend: Option<i32>,
    pub suspend_until: Option<String>,
}

ExportableQueuedJob : Queued job with full data for export/import operations

Fields

id: Uuid

parent_job: Option<Uuid>

created_by: String

created_at: String

started_at: Option<String>

scheduled_for: Option<String>

script_path: Option<String>

script_hash: Option<String>

args: Option<Value>

Full job arguments without size restrictions

logs: Option<String>

Complete job logs from v2_job table

raw_code: Option<String>

raw_lock: Option<String>

canceled_by: Option<String>

canceled_reason: Option<String>

job_kind: JobKind

trigger: Option<String>

Trigger path for the job (replaces schedule_path)

trigger_kind: Option<TriggerKind>

permissioned_as: String

permissioned_as_email: Option<String>

flow_status: Option<Value>

Flow status from v2_job_status table

workflow_as_code_status: Option<Value>

raw_flow: Option<Value>

is_flow_step: Option<bool>

language: Option<ScriptLang>

email: String

visible_to_owner: bool

mem_peak: Option<i32>

tag: Option<String>

priority: Option<i32>

labels: Option<Vec<String>>

same_worker: Option<bool>

flow_step_id: Option<String>

flow_innermost_root_job: Option<Uuid>

concurrent_limit: Option<i32>

concurrency_time_window_s: Option<i32>

timeout: Option<i32>

cache_ttl: Option<i32>

self_wait_time_ms: Option<i32>

aggregate_wait_time_ms: Option<i32>

preprocessed: Option<bool>

suspend: Option<i32>

suspend_until: Option<String>

Implementations

impl ExportableQueuedJob

pub fn new( id: Uuid, created_by: String, created_at: String, job_kind: JobKind, permissioned_as: String, email: String, visible_to_owner: bool, ) -> ExportableQueuedJob

Queued job with full data for export/import operations

Trait Implementations

impl Clone for ExportableQueuedJob

fn clone(&self) -> ExportableQueuedJob

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExportableQueuedJob

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

Formats the value using the given formatter.

impl Default for ExportableQueuedJob

fn default() -> ExportableQueuedJob

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExportableQueuedJob

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ExportableQueuedJob

fn eq(&self, other: &ExportableQueuedJob) -> 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 ExportableQueuedJob

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 ExportableQueuedJob