airflow.providers.edge.cli.edge_command¶
Module Contents¶
Functions¶
Ensure that the environment is configured for the internal API without needing to declare it outside. |
|
|
Start Airflow Edge Worker. |
|
Stop a running Airflow Edge Worker. |
Attributes¶
- airflow.providers.edge.cli.edge_command.force_use_internal_api_on_edge_worker()[source]¶
Ensure that the environment is configured for the internal API without needing to declare it outside.
This is only required for an Edge worker and must to be done before the Click CLI wrapper is initiated. That is because the CLI wrapper will attempt to establish a DB connection, which will fail before the function call can take effect. In an Edge worker, we need to “patch” the environment before starting.