• Home
• Index

Index

_

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

__version__ (in module airflow.providers.edge)

A

add_queues() (airflow.providers.edge.models.edge_worker.EdgeWorkerModel method) airflow.providers.edge module airflow.providers.edge.cli module airflow.providers.edge.cli.api_client module airflow.providers.edge.cli.edge_command module airflow.providers.edge.executors module airflow.providers.edge.executors.edge_executor module airflow.providers.edge.models module airflow.providers.edge.models.edge_job module airflow.providers.edge.models.edge_logs module airflow.providers.edge.models.edge_worker module airflow.providers.edge.openapi module airflow.providers.edge.plugins module airflow.providers.edge.plugins.edge_executor_plugin module airflow.providers.edge.version_compat module

airflow.providers.edge.worker_api module airflow.providers.edge.worker_api.app module airflow.providers.edge.worker_api.auth module airflow.providers.edge.worker_api.datamodels module airflow.providers.edge.worker_api.routes module airflow.providers.edge.worker_api.routes._v2_compat module airflow.providers.edge.worker_api.routes._v2_routes module airflow.providers.edge.worker_api.routes.health module airflow.providers.edge.worker_api.routes.jobs module airflow.providers.edge.worker_api.routes.logs module airflow.providers.edge.worker_api.routes.worker module AIRFLOW_V_2_10_PLUS (in module airflow.providers.edge.version_compat) AIRFLOW_V_3_0_PLUS (in module airflow.providers.edge.version_compat) ARG_CONCURRENCY (in module airflow.providers.edge.cli.edge_command) ARG_EDGE_HOSTNAME (in module airflow.providers.edge.cli.edge_command) ARG_QUEUES (in module airflow.providers.edge.cli.edge_command)

B

Body (class in airflow.providers.edge.worker_api.routes._v2_compat)

C

command (airflow.providers.edge.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge.worker_api.datamodels.EdgeJobFetched attribute)

concurrency_slots (airflow.providers.edge.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge.worker_api.datamodels.EdgeJobFetched attribute) create_edge_worker_api_app() (in module airflow.providers.edge.worker_api.app)

D

dag_id (airflow.providers.edge.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge.worker_api.datamodels.EdgeJobBase attribute) (airflow.providers.edge.worker_api.datamodels.WorkerApiDocs attribute)

default_view (airflow.providers.edge.plugins.edge_executor_plugin.EdgeWorkerHosts attribute) (airflow.providers.edge.plugins.edge_executor_plugin.EdgeWorkerJobs attribute)

E

EDGE_COMMANDS (in module airflow.providers.edge.cli.edge_command) EDGE_EXECUTOR_ACTIVE (in module airflow.providers.edge.plugins.edge_executor_plugin) edge_worker (airflow.providers.edge.models.edge_job.EdgeJobModel attribute) EDGE_WORKER_HEADER (in module airflow.providers.edge.cli.edge_command) EDGE_WORKER_PROCESS_NAME (in module airflow.providers.edge.cli.edge_command) EdgeExecutor (class in airflow.providers.edge.executors.edge_executor) EdgeExecutorPlugin (class in airflow.providers.edge.plugins.edge_executor_plugin) EdgeJobBase (class in airflow.providers.edge.worker_api.datamodels) EdgeJobFetched (class in airflow.providers.edge.worker_api.datamodels)

EdgeJobModel (class in airflow.providers.edge.models.edge_job) EdgeLogsModel (class in airflow.providers.edge.models.edge_logs) EdgeWorkerHosts (class in airflow.providers.edge.plugins.edge_executor_plugin) EdgeWorkerJobs (class in airflow.providers.edge.plugins.edge_executor_plugin) EdgeWorkerModel (class in airflow.providers.edge.models.edge_worker) EdgeWorkerState (class in airflow.providers.edge.models.edge_worker) EdgeWorkerVersionException end() (airflow.providers.edge.executors.edge_executor.EdgeExecutor method) error_response() (in module airflow.providers.edge.worker_api.routes._v2_routes) execute_async() (airflow.providers.edge.executors.edge_executor.EdgeExecutor method)

F

fetch() (in module airflow.providers.edge.worker_api.routes.jobs) first_online (airflow.providers.edge.models.edge_worker.EdgeWorkerModel attribute)

force_use_internal_api_on_edge_worker() (in module airflow.providers.edge.cli.edge_command) free_concurrency (airflow.providers.edge.worker_api.datamodels.WorkerQueuesBody attribute)

G

get_base_airflow_version_tuple() (in module airflow.providers.edge.version_compat)

get_cli_commands() (airflow.providers.edge.executors.edge_executor.EdgeExecutor static method)

H

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

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

I

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

J

job_fetch_v2() (in module airflow.providers.edge.worker_api.routes._v2_routes) job_state_v2() (in module airflow.providers.edge.worker_api.routes._v2_routes) jobs() (airflow.providers.edge.plugins.edge_executor_plugin.EdgeWorkerJobs method) jobs_active (airflow.providers.edge.models.edge_worker.EdgeWorkerModel attribute) (airflow.providers.edge.worker_api.datamodels.WorkerStateBody attribute) jobs_failed (airflow.providers.edge.models.edge_worker.EdgeWorkerModel attribute) jobs_fetch() (in module airflow.providers.edge.cli.api_client) jobs_router (in module airflow.providers.edge.worker_api.routes.jobs) jobs_set_state() (in module airflow.providers.edge.cli.api_client)

jobs_success (airflow.providers.edge.models.edge_worker.EdgeWorkerModel attribute) jobs_taken (airflow.providers.edge.models.edge_worker.EdgeWorkerModel attribute) jsonrpc (airflow.providers.edge.worker_api.datamodels.JsonRpcRequest attribute) JsonRpcRequest (class in airflow.providers.edge.worker_api.datamodels) JsonRpcRequestBase (class in airflow.providers.edge.worker_api.datamodels) jwt_signer() (in module airflow.providers.edge.worker_api.auth) jwt_token_authorization() (in module airflow.providers.edge.worker_api.auth) jwt_token_authorization_rest() (in module airflow.providers.edge.worker_api.auth) jwt_token_authorization_rpc() (in module airflow.providers.edge.worker_api.auth)

K

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

L

last_update (airflow.providers.edge.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge.models.edge_worker.EdgeWorkerModel attribute) last_update_t (airflow.providers.edge.models.edge_job.EdgeJobModel property) log (in module airflow.providers.edge.worker_api.auth) (in module airflow.providers.edge.worker_api.routes._v2_routes) log_chunk_data (airflow.providers.edge.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge.worker_api.datamodels.PushLogsBody attribute) log_chunk_time (airflow.providers.edge.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge.worker_api.datamodels.PushLogsBody attribute)

logfile_path() (in module airflow.providers.edge.worker_api.routes.logs) logfile_path_v2() (in module airflow.providers.edge.worker_api.routes._v2_routes) logger (in module airflow.providers.edge.cli.api_client) (in module airflow.providers.edge.cli.edge_command) logs_logfile_path() (in module airflow.providers.edge.cli.api_client) logs_push() (in module airflow.providers.edge.cli.api_client) logs_router (in module airflow.providers.edge.worker_api.routes.logs)

M

map_index (airflow.providers.edge.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge.worker_api.datamodels.EdgeJobBase attribute) (airflow.providers.edge.worker_api.datamodels.WorkerApiDocs attribute) method (airflow.providers.edge.worker_api.datamodels.JsonRpcRequestBase attribute) module airflow.providers.edge airflow.providers.edge.cli airflow.providers.edge.cli.api_client airflow.providers.edge.cli.edge_command airflow.providers.edge.executors airflow.providers.edge.executors.edge_executor airflow.providers.edge.models airflow.providers.edge.models.edge_job airflow.providers.edge.models.edge_logs airflow.providers.edge.models.edge_worker airflow.providers.edge.openapi airflow.providers.edge.plugins airflow.providers.edge.plugins.edge_executor_plugin airflow.providers.edge.version_compat airflow.providers.edge.worker_api airflow.providers.edge.worker_api.app airflow.providers.edge.worker_api.auth airflow.providers.edge.worker_api.datamodels airflow.providers.edge.worker_api.routes airflow.providers.edge.worker_api.routes._v2_compat airflow.providers.edge.worker_api.routes._v2_routes airflow.providers.edge.worker_api.routes.health airflow.providers.edge.worker_api.routes.jobs airflow.providers.edge.worker_api.routes.logs airflow.providers.edge.worker_api.routes.worker

N

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

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

O

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

P

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

push_logs() (in module airflow.providers.edge.worker_api.routes.logs) push_logs_v2() (in module airflow.providers.edge.worker_api.routes._v2_routes) PushLogsBody (class in airflow.providers.edge.worker_api.datamodels)

Q

queue (airflow.providers.edge.models.edge_job.EdgeJobModel attribute) queued_dttm (airflow.providers.edge.models.edge_job.EdgeJobModel attribute)

queues (airflow.providers.edge.models.edge_worker.EdgeWorkerModel property) (airflow.providers.edge.worker_api.datamodels.WorkerQueuesBase attribute) (airflow.providers.edge.worker_api.datamodels.WorkerStateBody attribute)

R

register() (in module airflow.providers.edge.worker_api.routes.worker) register_v2() (in module airflow.providers.edge.worker_api.routes._v2_routes) remove_queues (airflow.providers.edge.worker_api.datamodels.WorkerQueueUpdateBody attribute) remove_queues() (airflow.providers.edge.models.edge_worker.EdgeWorkerModel method) reset_metrics() (in module airflow.providers.edge.models.edge_worker)

rpcapi_v2() (in module airflow.providers.edge.worker_api.routes._v2_routes) run_id (airflow.providers.edge.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge.worker_api.datamodels.EdgeJobBase attribute) (airflow.providers.edge.worker_api.datamodels.WorkerApiDocs attribute) RUNNING (airflow.providers.edge.models.edge_worker.EdgeWorkerState attribute)

S

set_metrics() (in module airflow.providers.edge.models.edge_worker) set_state() (in module airflow.providers.edge.worker_api.routes.worker) set_state_v2() (in module airflow.providers.edge.worker_api.routes._v2_routes) start() (airflow.providers.edge.executors.edge_executor.EdgeExecutor method) STARTING (airflow.providers.edge.models.edge_worker.EdgeWorkerState attribute) state (airflow.providers.edge.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge.models.edge_worker.EdgeWorkerModel attribute) (airflow.providers.edge.worker_api.datamodels.WorkerApiDocs attribute) (airflow.providers.edge.worker_api.datamodels.WorkerStateBody attribute)

state() (in module airflow.providers.edge.worker_api.routes.jobs) status() (airflow.providers.edge.plugins.edge_executor_plugin.EdgeWorkerHosts method) stop() (in module airflow.providers.edge.cli.edge_command) sync() (airflow.providers.edge.executors.edge_executor.EdgeExecutor method) sysinfo (airflow.providers.edge.models.edge_worker.EdgeWorkerModel attribute) (airflow.providers.edge.worker_api.datamodels.WorkerStateBody attribute) sysinfo_json (airflow.providers.edge.models.edge_worker.EdgeWorkerModel property)

T

task_id (airflow.providers.edge.models.edge_job.EdgeJobModel attribute) (airflow.providers.edge.models.edge_logs.EdgeLogsModel attribute) (airflow.providers.edge.worker_api.datamodels.EdgeJobBase attribute) (airflow.providers.edge.worker_api.datamodels.WorkerApiDocs attribute) TaskTuple (in module airflow.providers.edge.executors.edge_executor) template_bp (in module airflow.providers.edge.plugins.edge_executor_plugin)

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

U

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

update_queues() (in module airflow.providers.edge.worker_api.routes.worker)

W

worker() (in module airflow.providers.edge.cli.edge_command) worker_name (airflow.providers.edge.models.edge_worker.EdgeWorkerModel attribute) worker_register() (in module airflow.providers.edge.cli.api_client) worker_router (in module airflow.providers.edge.worker_api.routes.worker) worker_set_state() (in module airflow.providers.edge.cli.api_client)

WorkerApiDocs (class in airflow.providers.edge.worker_api.datamodels) WorkerQueuesBase (class in airflow.providers.edge.worker_api.datamodels) WorkerQueuesBody (class in airflow.providers.edge.worker_api.datamodels) WorkerQueueUpdateBody (class in airflow.providers.edge.worker_api.datamodels) WorkerStateBody (class in airflow.providers.edge.worker_api.datamodels)

PreviousNext

Was this entry helpful?