Enum ConnectorRunStatus 

pub enum ConnectorRunStatus {
    Succeeded,
    Failed,
    Timeout,
}

The terminal state of a connector-managed run as observed by the connector.

Connectors use this enum to represent their own job/task states before mapping them to the Floe-normalized RunStatus. The mapping is deliberately coarse: fine-grained outcomes (e.g. Rejected, Aborted) can only be inferred from the in-pod parse_run_status_from_logs helper.

Variants

Succeeded

The job/task completed without infrastructure error.

The actual logical outcome (success, rejected, …) must be read from the pod/task logs via parse_run_status_from_logs.

Failed

The job/task failed at the infrastructure level (non-zero exit, pod OOM, etc.) before or without emitting a run_finished event.

Timeout

The connector’s timeout elapsed before the job/task reached a terminal state.

Implementations

impl ConnectorRunStatus

pub fn to_run_status(self) -> RunStatus

Map to a Floe RunStatus suitable for a summary report.

Use parse_run_status_from_logs first to obtain a finer-grained status from pod logs; only fall back to this mapping when logs are unavailable or parsing fails.

pub fn exit_code(self) -> i32

Conventional exit code for use in summary reports.

Trait Implementations

impl Clone for ConnectorRunStatus

fn clone(&self) -> ConnectorRunStatus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectorRunStatus

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

Formats the value using the given formatter.

impl PartialEq for ConnectorRunStatus

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

impl Eq for ConnectorRunStatus

impl StructuralPartialEq for ConnectorRunStatus