airflow.providers.edge3.cli.worker¶
Attributes¶
Classes¶
Runner instance which executes the Edge Worker. |
Module Contents¶
- class airflow.providers.edge3.cli.worker.EdgeWorker(pid_file_path, hostname, queues, concurrency, job_poll_interval, heartbeat_interval, daemon=False)[source]¶
Runner instance which executes the Edge Worker.
- jobs: list[airflow.providers.edge3.cli.dataclasses.Job] = [][source]¶
List of jobs that the worker is running currently.
- last_hb: datetime.datetime | None = None[source]¶
Timestamp of last heart beat sent to server.
- drain: bool = False[source]¶
Flag if job processing should be completed and no new jobs fetched for a graceful stop/shutdown.
- maintenance_mode: bool = False[source]¶
Flag if job processing should be completed and no new jobs fetched for maintenance mode.
- edge_instance: EdgeWorker | None = None[source]¶
Singleton instance of the worker.