• Home
• Index

Index

_

__table_args__ (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) __tablename__ (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge3.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel attribute)

__version__ (in module airflow.providers.edge3)

A

add_queues() (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel method) airflow.providers.edge3 module airflow.providers.edge3.cli module airflow.providers.edge3.cli.api_client module airflow.providers.edge3.cli.dataclasses module airflow.providers.edge3.cli.edge_command module airflow.providers.edge3.cli.signalling module airflow.providers.edge3.cli.worker module airflow.providers.edge3.example_dags module airflow.providers.edge3.example_dags.integration_test module airflow.providers.edge3.example_dags.win_notepad module airflow.providers.edge3.example_dags.win_test module airflow.providers.edge3.executors module airflow.providers.edge3.executors.edge_executor module airflow.providers.edge3.get_provider_info module airflow.providers.edge3.models module airflow.providers.edge3.models.edge_job module airflow.providers.edge3.models.edge_logs module airflow.providers.edge3.models.edge_worker module airflow.providers.edge3.openapi module airflow.providers.edge3.plugins module airflow.providers.edge3.plugins.edge_executor_plugin module

airflow.providers.edge3.version_compat module airflow.providers.edge3.worker_api module airflow.providers.edge3.worker_api.app module airflow.providers.edge3.worker_api.auth module airflow.providers.edge3.worker_api.datamodels module airflow.providers.edge3.worker_api.routes module airflow.providers.edge3.worker_api.routes.health module airflow.providers.edge3.worker_api.routes.jobs module airflow.providers.edge3.worker_api.routes.logs module airflow.providers.edge3.worker_api.routes.worker module AIRFLOW_V_3_0_PLUS (in module airflow.providers.edge3.version_compat) API_RETRIES (in module airflow.providers.edge3.cli.api_client) API_RETRY_WAIT_MAX (in module airflow.providers.edge3.cli.api_client) API_RETRY_WAIT_MIN (in module airflow.providers.edge3.cli.api_client) append_env (airflow.providers.edge3.example_dags.win_test.CmdOperator attribute) ARG_CONCURRENCY (in module airflow.providers.edge3.cli.edge_command) ARG_DAEMON (in module airflow.providers.edge3.cli.edge_command) ARG_EDGE_HOSTNAME (in module airflow.providers.edge3.cli.edge_command) ARG_LOG_FILE (in module airflow.providers.edge3.cli.edge_command) ARG_MAINTENANCE (in module airflow.providers.edge3.cli.edge_command) ARG_MAINTENANCE_COMMENT (in module airflow.providers.edge3.cli.edge_command) ARG_OUTPUT (in module airflow.providers.edge3.cli.edge_command) ARG_QUEUES (in module airflow.providers.edge3.cli.edge_command) ARG_REQUIRED_EDGE_HOSTNAME (in module airflow.providers.edge3.cli.edge_command) ARG_REQUIRED_MAINTENANCE_COMMENT (in module airflow.providers.edge3.cli.edge_command) ARG_STATE (in module airflow.providers.edge3.cli.edge_command) ARG_STDERR (in module airflow.providers.edge3.cli.edge_command) ARG_STDOUT (in module airflow.providers.edge3.cli.edge_command) ARG_UMASK (in module airflow.providers.edge3.cli.edge_command) ARG_WAIT_MAINT (in module airflow.providers.edge3.cli.edge_command) ARG_WAIT_STOP (in module airflow.providers.edge3.cli.edge_command)

C

change_maintenance_comment() (in module airflow.providers.edge3.models.edge_worker) check_running_jobs() (airflow.providers.edge3.cli.worker.EdgeWorker method) CmdOperator (class in airflow.providers.edge3.example_dags.win_test) command (airflow.providers.edge3.example_dags.win_test.CmdOperator attribute) (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge3.worker_api.datamodels.EdgeJobFetched attribute)

CommandType (in module airflow.providers.edge3.executors.edge_executor) comments (airflow.providers.edge3.cli.dataclasses.MaintenanceMarker attribute) concurrency (airflow.providers.edge3.cli.worker.EdgeWorker attribute) concurrency_slots (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge3.worker_api.datamodels.EdgeJobFetched attribute) create_edge_worker_api_app() (in module airflow.providers.edge3.worker_api.app) cwd (airflow.providers.edge3.example_dags.win_test.CmdOperator attribute)

D

daemon (airflow.providers.edge3.cli.worker.EdgeWorker attribute) dag_id (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge3.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge3.worker_api.datamodels.EdgeJobBase attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerApiDocs attribute)

drain (airflow.providers.edge3.cli.dataclasses.WorkerStatus attribute) (airflow.providers.edge3.cli.worker.EdgeWorker attribute)

E

EDGE_COMMANDS (in module airflow.providers.edge3.cli.edge_command) EDGE_EXECUTOR_ACTIVE (in module airflow.providers.edge3.plugins.edge_executor_plugin) edge_instance (airflow.providers.edge3.cli.worker.EdgeWorker attribute) edge_job (airflow.providers.edge3.cli.dataclasses.Job attribute) edge_worker (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) EDGE_WORKER_HEADER (in module airflow.providers.edge3.cli.edge_command) EDGE_WORKER_PROCESS_NAME (in module airflow.providers.edge3.cli.signalling) EdgeExecutor (class in airflow.providers.edge3.executors.edge_executor) EdgeExecutorPlugin (class in airflow.providers.edge3.plugins.edge_executor_plugin) EdgeJobBase (class in airflow.providers.edge3.worker_api.datamodels) EdgeJobFetched (class in airflow.providers.edge3.worker_api.datamodels)

EdgeJobModel (class in airflow.providers.edge3.models.edge_job) EdgeLogsModel (class in airflow.providers.edge3.models.edge_logs) EdgeWorker (class in airflow.providers.edge3.cli.worker) EdgeWorkerModel (class in airflow.providers.edge3.models.edge_worker) EdgeWorkerState (class in airflow.providers.edge3.models.edge_worker) EdgeWorkerVersionException end() (airflow.providers.edge3.executors.edge_executor.EdgeExecutor method) env (airflow.providers.edge3.example_dags.win_test.CmdOperator attribute) execute() (airflow.providers.edge3.example_dags.win_notepad.NotepadOperator method) (airflow.providers.edge3.example_dags.win_test.CmdOperator method) execute_async() (airflow.providers.edge3.executors.edge_executor.EdgeExecutor method) exit_maintenance() (in module airflow.providers.edge3.models.edge_worker)

F

fastapi_apps (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeExecutorPlugin attribute) fetch() (in module airflow.providers.edge3.worker_api.routes.jobs) fetch_job() (airflow.providers.edge3.cli.worker.EdgeWorker method) first_online (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel attribute)

force_use_internal_api_on_edge_worker() (in module airflow.providers.edge3.cli.edge_command) free_concurrency (airflow.providers.edge3.cli.worker.EdgeWorker attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerQueuesBody attribute) from_json() (airflow.providers.edge3.cli.dataclasses.MaintenanceMarker static method) (airflow.providers.edge3.cli.dataclasses.WorkerStatus static method)

G

get_base_airflow_version_tuple() (in module airflow.providers.edge3.version_compat) get_cli_commands() (airflow.providers.edge3.executors.edge_executor.EdgeExecutor static method) get_env() (airflow.providers.edge3.example_dags.win_test.CmdOperator method)

get_pid() (in module airflow.providers.edge3.cli.signalling) get_provider_info() (in module airflow.providers.edge3.get_provider_info) get_registered_edge_hosts() (in module airflow.providers.edge3.models.edge_worker)

H

hb_interval (airflow.providers.edge3.cli.worker.EdgeWorker attribute) health() (in module airflow.providers.edge3.worker_api.routes.health)

health_router (in module airflow.providers.edge3.worker_api.routes.health) heartbeat() (airflow.providers.edge3.cli.worker.EdgeWorker method) hostname (airflow.providers.edge3.cli.worker.EdgeWorker attribute)

I

IDLE (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute) interruptible_sleep() (airflow.providers.edge3.cli.worker.EdgeWorker method)

is_running (airflow.providers.edge3.cli.dataclasses.Job property) is_success (airflow.providers.edge3.cli.dataclasses.Job property)

J

Job (class in airflow.providers.edge3.cli.dataclasses) job_count (airflow.providers.edge3.cli.dataclasses.WorkerStatus attribute) job_poll_interval (airflow.providers.edge3.cli.worker.EdgeWorker attribute) jobs (airflow.providers.edge3.cli.dataclasses.WorkerStatus attribute) (airflow.providers.edge3.cli.worker.EdgeWorker attribute) jobs_active (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerStateBody attribute) jobs_failed (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel attribute) jobs_fetch() (in module airflow.providers.edge3.cli.api_client) jobs_router (in module airflow.providers.edge3.worker_api.routes.jobs) jobs_set_state() (in module airflow.providers.edge3.cli.api_client)

jobs_success (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel attribute) jobs_taken (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel attribute) json (airflow.providers.edge3.cli.dataclasses.MaintenanceMarker property) (airflow.providers.edge3.cli.dataclasses.WorkerStatus property) jsonrpc (airflow.providers.edge3.worker_api.datamodels.JsonRpcRequest attribute) JsonRpcRequest (class in airflow.providers.edge3.worker_api.datamodels) JsonRpcRequestBase (class in airflow.providers.edge3.worker_api.datamodels) jwt_token_authorization() (in module airflow.providers.edge3.worker_api.auth) jwt_token_authorization_rest() (in module airflow.providers.edge3.worker_api.auth) jwt_token_authorization_rpc() (in module airflow.providers.edge3.worker_api.auth) jwt_validator() (in module airflow.providers.edge3.worker_api.auth)

K

key (airflow.providers.edge3.models.edge_job.EdgeJobModel property) (airflow.providers.edge3.worker_api.datamodels.EdgeJobBase property)

L

last_hb (airflow.providers.edge3.cli.worker.EdgeWorker attribute) last_reported_state (airflow.providers.edge3.executors.edge_executor.EdgeExecutor attribute) last_update (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerRegistrationReturn attribute) last_update_t (airflow.providers.edge3.models.edge_job.EdgeJobModel property) list_edge_workers() (in module airflow.providers.edge3.cli.edge_command) log (in module airflow.providers.edge3.worker_api.auth) log_chunk_data (airflow.providers.edge3.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge3.worker_api.datamodels.PushLogsBody attribute) log_chunk_time (airflow.providers.edge3.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge3.worker_api.datamodels.PushLogsBody attribute)

logfile (airflow.providers.edge3.cli.dataclasses.Job attribute) logfile_path() (in module airflow.providers.edge3.worker_api.routes.logs) logger (in module airflow.providers.edge3.cli.api_client) (in module airflow.providers.edge3.cli.edge_command) (in module airflow.providers.edge3.cli.signalling) (in module airflow.providers.edge3.cli.worker) (in module airflow.providers.edge3.models.edge_worker) logs_logfile_path() (in module airflow.providers.edge3.cli.api_client) logs_push() (in module airflow.providers.edge3.cli.api_client) logs_router (in module airflow.providers.edge3.worker_api.routes.logs) logsize (airflow.providers.edge3.cli.dataclasses.Job attribute) loop() (airflow.providers.edge3.cli.worker.EdgeWorker method)

M

maintenance (airflow.providers.edge3.cli.dataclasses.MaintenanceMarker attribute) (airflow.providers.edge3.cli.dataclasses.WorkerStatus attribute) maintenance() (in module airflow.providers.edge3.cli.edge_command) maintenance_comment (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel attribute) maintenance_comments (airflow.providers.edge3.cli.dataclasses.WorkerStatus attribute) (airflow.providers.edge3.cli.worker.EdgeWorker attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerSetStateReturn attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerStateBody attribute) MAINTENANCE_EXIT (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute) maintenance_marker_file_path() (in module airflow.providers.edge3.cli.signalling) maintenance_mode (airflow.providers.edge3.cli.worker.EdgeWorker attribute) MAINTENANCE_MODE (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute) MAINTENANCE_PENDING (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute) MAINTENANCE_REQUEST (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute) MaintenanceMarker (class in airflow.providers.edge3.cli.dataclasses) map_index (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge3.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge3.worker_api.datamodels.EdgeJobBase attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerApiDocs attribute) method (airflow.providers.edge3.worker_api.datamodels.JsonRpcRequestBase attribute) module airflow.providers.edge3 airflow.providers.edge3.cli airflow.providers.edge3.cli.api_client airflow.providers.edge3.cli.dataclasses airflow.providers.edge3.cli.edge_command airflow.providers.edge3.cli.signalling airflow.providers.edge3.cli.worker airflow.providers.edge3.example_dags airflow.providers.edge3.example_dags.integration_test airflow.providers.edge3.example_dags.win_notepad airflow.providers.edge3.example_dags.win_test airflow.providers.edge3.executors airflow.providers.edge3.executors.edge_executor airflow.providers.edge3.get_provider_info airflow.providers.edge3.models airflow.providers.edge3.models.edge_job airflow.providers.edge3.models.edge_logs airflow.providers.edge3.models.edge_worker airflow.providers.edge3.openapi airflow.providers.edge3.plugins airflow.providers.edge3.plugins.edge_executor_plugin airflow.providers.edge3.version_compat airflow.providers.edge3.worker_api airflow.providers.edge3.worker_api.app airflow.providers.edge3.worker_api.auth airflow.providers.edge3.worker_api.datamodels airflow.providers.edge3.worker_api.routes airflow.providers.edge3.worker_api.routes.health airflow.providers.edge3.worker_api.routes.jobs airflow.providers.edge3.worker_api.routes.logs airflow.providers.edge3.worker_api.routes.worker

my_setup() (in module airflow.providers.edge3.example_dags.integration_test) (in module airflow.providers.edge3.example_dags.win_test)

N

name (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeExecutorPlugin attribute) new_queues (airflow.providers.edge3.worker_api.datamodels.WorkerQueueUpdateBody attribute)

NotepadOperator (class in airflow.providers.edge3.example_dags.win_notepad) npo (in module airflow.providers.edge3.example_dags.win_notepad)

O

OFFLINE (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute) OFFLINE_MAINTENANCE (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute)

on_kill() (airflow.providers.edge3.example_dags.win_test.CmdOperator method) output_processor (airflow.providers.edge3.example_dags.win_test.CmdOperator attribute)

P

PARALLELISM (in module airflow.providers.edge3.executors.edge_executor) params (airflow.providers.edge3.worker_api.datamodels.JsonRpcRequest attribute) pid_file_path (airflow.providers.edge3.cli.worker.EdgeWorker attribute) pid_file_path() (in module airflow.providers.edge3.cli.signalling)

process (airflow.providers.edge3.cli.dataclasses.Job attribute) push_logs() (in module airflow.providers.edge3.worker_api.routes.logs) PushLogsBody (class in airflow.providers.edge3.worker_api.datamodels) put_remote_worker_on_maintenance() (in module airflow.providers.edge3.cli.edge_command)

Q

queue (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) queue_workload() (airflow.providers.edge3.executors.edge_executor.EdgeExecutor method) queued_dttm (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) queues (airflow.providers.edge3.cli.worker.EdgeWorker attribute) (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel property) (airflow.providers.edge3.worker_api.datamodels.WorkerQueuesBase attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerSetStateReturn attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerStateBody attribute)

R

redefine_maintenance_comments() (in module airflow.providers.edge3.worker_api.routes.worker) redefine_state() (in module airflow.providers.edge3.worker_api.routes.worker) refresh_command() (airflow.providers.edge3.example_dags.win_test.CmdOperator static method) register() (in module airflow.providers.edge3.worker_api.routes.worker) remote_worker_request_shutdown() (in module airflow.providers.edge3.cli.edge_command) remote_worker_update_maintenance_comment() (in module airflow.providers.edge3.cli.edge_command) remove_queues (airflow.providers.edge3.worker_api.datamodels.WorkerQueueUpdateBody attribute) remove_queues() (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel method) remove_remote_worker() (in module airflow.providers.edge3.cli.edge_command)

remove_remote_worker_from_maintenance() (in module airflow.providers.edge3.cli.edge_command) remove_worker() (in module airflow.providers.edge3.models.edge_worker) request_maintenance() (in module airflow.providers.edge3.models.edge_worker) request_shutdown() (in module airflow.providers.edge3.models.edge_worker) reset_metrics() (in module airflow.providers.edge3.models.edge_worker) run_id (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge3.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge3.worker_api.datamodels.EdgeJobBase attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerApiDocs attribute) RUNNING (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute)

S

set_metrics() (in module airflow.providers.edge3.models.edge_worker) set_state() (in module airflow.providers.edge3.worker_api.routes.worker) shutdown_handler() (airflow.providers.edge3.cli.worker.EdgeWorker method) SHUTDOWN_REQUEST (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute) SIG_STATUS (in module airflow.providers.edge3.cli.signalling) signal_handler() (airflow.providers.edge3.cli.worker.EdgeWorker static method) skip_on_exit_code (airflow.providers.edge3.example_dags.win_test.CmdOperator attribute) start() (airflow.providers.edge3.cli.worker.EdgeWorker method) (airflow.providers.edge3.executors.edge_executor.EdgeExecutor method) STARTING (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute) state (airflow.providers.edge3.cli.dataclasses.WorkerStatus attribute) (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerApiDocs attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerSetStateReturn attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerStateBody attribute)

state() (in module airflow.providers.edge3.worker_api.routes.jobs) status() (in module airflow.providers.edge3.cli.edge_command) status_file_path() (in module airflow.providers.edge3.cli.signalling) stop() (in module airflow.providers.edge3.cli.edge_command) subprocess (airflow.providers.edge3.example_dags.win_test.CmdOperator attribute) sync() (airflow.providers.edge3.executors.edge_executor.EdgeExecutor method) sysinfo (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerStateBody attribute) sysinfo_json (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel property)

T

task_id (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge3.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge3.worker_api.datamodels.EdgeJobBase attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerApiDocs attribute) template_ext (airflow.providers.edge3.example_dags.win_test.CmdOperator attribute) template_fields (airflow.providers.edge3.example_dags.win_notepad.NotepadOperator attribute) (airflow.providers.edge3.example_dags.win_test.CmdOperator attribute) template_fields_renderers (airflow.providers.edge3.example_dags.win_test.CmdOperator attribute)

terminate() (airflow.providers.edge3.executors.edge_executor.EdgeExecutor method) TERMINATING (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute) text (airflow.providers.edge3.example_dags.win_notepad.NotepadOperator attribute) try_adopt_task_instances() (airflow.providers.edge3.executors.edge_executor.EdgeExecutor method) try_number (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge3.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge3.worker_api.datamodels.EdgeJobBase attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerApiDocs attribute)

U

UNKNOWN (airflow.providers.edge3.models.edge_worker.EdgeWorkerState attribute)

update_queues() (in module airflow.providers.edge3.worker_api.routes.worker) update_state() (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel method)

W

worker() (in module airflow.providers.edge3.cli.edge_command) worker_name (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel attribute) worker_register() (in module airflow.providers.edge3.cli.api_client) worker_router (in module airflow.providers.edge3.worker_api.routes.worker) worker_set_state() (in module airflow.providers.edge3.cli.api_client) WorkerApiDocs (class in airflow.providers.edge3.worker_api.datamodels) WorkerQueuesBase (class in airflow.providers.edge3.worker_api.datamodels)

WorkerQueuesBody (class in airflow.providers.edge3.worker_api.datamodels) WorkerQueueUpdateBody (class in airflow.providers.edge3.worker_api.datamodels) WorkerRegistrationReturn (class in airflow.providers.edge3.worker_api.datamodels) WorkerSetStateReturn (class in airflow.providers.edge3.worker_api.datamodels) WorkerStateBody (class in airflow.providers.edge3.worker_api.datamodels) WorkerStatus (class in airflow.providers.edge3.cli.dataclasses) write_pid_to_pidfile() (in module airflow.providers.edge3.cli.signalling)

PreviousNext

Was this entry helpful?