• 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.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_2_10_PLUS (in module airflow.providers.edge3.version_compat) 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) appbuilder_views (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeExecutorPlugin attribute) ARG_CONCURRENCY (in module airflow.providers.edge3.cli.edge_command) ARG_EDGE_HOSTNAME (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_QUEUES (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() (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeWorkerHosts method) (in module airflow.providers.edge3.models.edge_worker) command (airflow.providers.edge3.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge3.worker_api.datamodels.EdgeJobFetched attribute)

comments (airflow.providers.edge3.cli.dataclasses.MaintenanceMarker 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)

D

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)

default_view (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeWorkerHosts attribute) (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeWorkerJobs attribute) drain (airflow.providers.edge3.cli.dataclasses.WorkerStatus 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_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.edge_command) 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) EdgeWorkerHosts (class in airflow.providers.edge3.plugins.edge_executor_plugin) EdgeWorkerJobs (class in airflow.providers.edge3.plugins.edge_executor_plugin) 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) execute_async() (airflow.providers.edge3.executors.edge_executor.EdgeExecutor method) exit_maintenance() (in module airflow.providers.edge3.models.edge_worker)

F

fetch() (in module airflow.providers.edge3.worker_api.routes.jobs) 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.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_provider_info() (in module airflow.providers.edge3.get_provider_info)

H

health() (in module airflow.providers.edge3.worker_api.routes.health)

health_router (in module airflow.providers.edge3.worker_api.routes.health)

I

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

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) jobs (airflow.providers.edge3.cli.dataclasses.WorkerStatus attribute) jobs() (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeWorkerJobs method) 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_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) 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) 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)

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.worker_api.datamodels.WorkerSetStateReturn attribute) (airflow.providers.edge3.worker_api.datamodels.WorkerStateBody attribute) MAINTENANCE_EXIT (airflow.providers.edge3.models.edge_worker.EdgeWorkerState 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) modify_maintenance_comment_on_update() (in module airflow.providers.edge3.plugins.edge_executor_plugin) 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.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

N

name (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeExecutorPlugin attribute)

new_queues (airflow.providers.edge3.worker_api.datamodels.WorkerQueueUpdateBody attribute)

O

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

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

P

PARALLELISM (in module airflow.providers.edge3.executors.edge_executor) params (airflow.providers.edge3.worker_api.datamodels.JsonRpcRequest attribute)

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)

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.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) register() (in module airflow.providers.edge3.worker_api.routes.worker) remove_queues (airflow.providers.edge3.worker_api.datamodels.WorkerQueueUpdateBody attribute) remove_queues() (airflow.providers.edge3.models.edge_worker.EdgeWorkerModel method) remove_worker() (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeWorkerHosts method) (in module airflow.providers.edge3.models.edge_worker)

remove_worker_from_maintenance() (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeWorkerHosts method) request_maintenance() (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) SIG_STATUS (in module airflow.providers.edge3.cli.edge_command) start() (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() (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeWorkerHosts method) (in module airflow.providers.edge3.cli.edge_command) stop() (in module airflow.providers.edge3.cli.edge_command) 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) TaskTuple (in module airflow.providers.edge3.executors.edge_executor) template_bp (in module airflow.providers.edge3.plugins.edge_executor_plugin)

terminate() (airflow.providers.edge3.executors.edge_executor.EdgeExecutor method) TERMINATING (airflow.providers.edge3.models.edge_worker.EdgeWorkerState 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) worker_to_maintenance() (airflow.providers.edge3.plugins.edge_executor_plugin.EdgeWorkerHosts method) 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)

PreviousNext

Was this entry helpful?