`airflow.providers.edge.cli.api_client`¶

Module Contents¶

`worker_register`(hostname, state, queues, sysinfo)	Register worker with the Edge API.
`worker_set_state`(hostname, state, jobs_active, queues, ...)	Update the state of the worker in the central site and thereby implicitly heartbeat.
`jobs_fetch`(hostname, queues, free_concurrency)	Fetch a job to execute on the edge worker.
`jobs_set_state`(key, state)	Set the state of a job.
`logs_logfile_path`(task)	Elaborate the path and filename to expect from task execution.
`logs_push`(task, log_chunk_time, log_chunk_data)	Push an incremental log chunk from Edge Worker to central site.

airflow.providers.edge.cli.api_client.worker_register(hostname, state, queues, sysinfo)[source]¶

Register worker with the Edge API.

airflow.providers.edge.cli.api_client.worker_set_state(hostname, state, jobs_active, queues, sysinfo)[source]¶

Update the state of the worker in the central site and thereby implicitly heartbeat.

airflow.providers.edge.cli.api_client.jobs_fetch(hostname, queues, free_concurrency)[source]¶

Fetch a job to execute on the edge worker.

airflow.providers.edge.cli.api_client.jobs_set_state(key, state)[source]¶

Set the state of a job.

airflow.providers.edge.cli.api_client.logs_logfile_path(task)[source]¶

Elaborate the path and filename to expect from task execution.

airflow.providers.edge.cli.api_client.logs_push(task, log_chunk_time, log_chunk_data)[source]¶

Push an incremental log chunk from Edge Worker to central site.