Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
23 commits
Select commit Hold shift + click to select a range
b60a73f
[AIRFLOW-YYY] Lazy load API Client
Nov 15, 2019
2a7c7d6
[AIRFLOW-YYY] Introduce order in CLI's function names
Nov 15, 2019
c1d6b26
[AIRFLOW-YYY] Create cli package
Nov 15, 2019
4083a5c
[AIRLFOW-YYY] Move user and roles command to seperate files
Nov 15, 2019
0c13f4e
[AIRLFOW-YYY] Move sync_perm command to seperate file
Nov 15, 2019
7092167
[AIRLFOW-YYY] Move task commands to separate file
Nov 15, 2019
5e41d28
[AIRLFOW-YYY] Move pool commands to separate file
Nov 17, 2019
a6712c0
[AIRLFOW-YYY] Move variable commands to separate file
Nov 17, 2019
f8f5d14
fixup! [AIRLFOW-YYY] Move variable commands to separate file
Nov 18, 2019
52564a0
[AIRLFOW-YYY] Move db commands to separate file
Nov 17, 2019
151bdbb
[AIRLFOW-YYY] Move connection commands to separate file
Nov 17, 2019
a3620b1
[AIRLFOW-YYY] Move version command to separate file
Nov 17, 2019
0b83099
[AIRLFOW-YYY] Move scheduler command to separate file
Nov 17, 2019
bca9088
[AIRLFOW-YYY] Move worker command to separate file
Nov 17, 2019
4b95f5c
[AIRLFOW-YYY] Move webserver command to separate file
Nov 17, 2019
ba70cc7
[AIRLFOW-YYY] Move dag commands to separate file
Nov 17, 2019
494491e
[AIRLFOW-YYY] Move serve logs command to separate file
Nov 17, 2019
6da4362
[AIRLFOW-YYY] Move flower command to separate file
Nov 17, 2019
c7ab4fa
[AIRLFOW-YYY] Move kerberos command to separate file
Nov 17, 2019
4f9c2e6
[AIRFLOW-YYY] Lazy load CLI commands
Nov 17, 2019
ebd350f
[AIRFLOW-YYY] Fix migration
Nov 17, 2019
504086d
fixup! [AIRFLOW-YYY] Fix migration
Nov 18, 2019
b40e73e
fixup! fixup! [AIRFLOW-YYY] Fix migration
Nov 18, 2019
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 0 additions & 1 deletion airflow/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,6 @@
from airflow.exceptions import AirflowException
from airflow.models import DAG


__version__ = version.version

settings.initialize()
Expand Down
20 changes: 20 additions & 0 deletions airflow/api/client/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,3 +16,23 @@
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
"""
API Client that allows interact with Airflow API
"""
from importlib import import_module
from typing import Any

from airflow import api, conf
from airflow.api.client.api_client import Client


def get_current_api_client() -> Client:
"""
Return current API Client depends on current Airflow configuration
"""
api_module = import_module(conf.get('cli', 'api_client')) # type: Any
api_client = api_module.Client(
api_base_url=conf.get('cli', 'endpoint_url'),
auth=api.API_AUTH.api_auth.CLIENT_AUTH
)
return api_client
Loading