airflow.providers.edge3.cli.dataclasses¶

Classes¶

`MaintenanceMarker`	Maintenance mode status.
`WorkerStatus`	Status of the worker.
`Job`	Holds all information for a task/job to be executed as bundle.

Module Contents¶

class airflow.providers.edge3.cli.dataclasses.MaintenanceMarker[source]¶

Maintenance mode status.

maintenance: str[source]¶

comments: str | None[source]¶

property json: str[source]¶

Get the maintenance status as JSON.

static from_json(json_str)[source]¶

Create a Maintenance object from JSON.

class airflow.providers.edge3.cli.dataclasses.WorkerStatus[source]¶

Status of the worker.

job_count: int[source]¶

jobs: list[source]¶

state: airflow.providers.edge3.models.edge_worker.EdgeWorkerState[source]¶

maintenance: bool[source]¶

maintenance_comments: str | None[source]¶

drain: bool[source]¶

property json: str[source]¶

Get the status as JSON.

static from_json(json_str)[source]¶

Create a WorkerStatus object from JSON.

class airflow.providers.edge3.cli.dataclasses.Job[source]¶

Holds all information for a task/job to be executed as bundle.

edge_job: airflow.providers.edge3.worker_api.datamodels.EdgeJobFetched[source]¶

process: subprocess.Popen | multiprocessing.Process[source]¶: Can be subprocess.Popen (for the spawn path) or multiprocessing.Process (for the fork path).

logfile: pathlib.Path[source]¶

logsize: int = 0[source]¶: Last size of log file, point of last chunk push.

stderr_file_path: pathlib.Path | None = None[source]¶: Path to file where error details are written on failure (stderr for subprocess path, traceback text for fork path).

property is_running: bool[source]¶

Check if the job is still running.

property is_success: bool[source]¶

Check if the job was successful.

failure_details()[source]¶

Format failure details, reading error text from the error file if available.

cleanup()[source]¶

Remove transient files owned by this job.

Was this entry helpful?