airflow_balancer.BalancerConfiguration

pydantic model airflow_balancer.BalancerConfiguration

Bases: BaseModel

field hosts: list[Host] [Optional]

field ports: list[Port] [Optional]

field default_username: str = 'airflow'

field default_password: str | Variable | None = None

field default_key_file: str | None = None

field primary_queue: str = 'default'

field secondary_queue: str = 'default'

field default_queue: str = 'default'

field default_size: int = 8

field override_pool_size: bool = False

field create_connection: bool = False

property all_hosts

property all_ports

filter_hosts(name: str | list[str] | None = None, queue: str | list[str] | None = None, os: str | list[str] | None = None, tag: str | list[str] | None = None, custom: Callable | None = None) → list[Host]

select_host(name: str | list[str] | None = None, queue: str | list[str] | None = None, os: str | list[str] = '', tag: str | list[str] = '', custom: Callable | None = None) → list[Host]

filter_ports(name: str | list[str] | None = None, tag: str | list[str] | None = None, custom: Callable | None = None) → list[Host]

select_port(name: str | list[str] | None = None, tag: str | list[str] = '', custom: Callable | None = None) → list[Host]

free_port(host: Host, min: int = 1000, max: int = 65535) → Port

static load_path(yaml_file: str | Path, _config_dir: str | Path | None = None) → Self

Load configuration from yaml file

static load(config_dir: Path | str = 'config', config_name: Path | str = '', overrides: list[str] | None = None, *, basepath: str = '', _offset: int = 4) → BalancerConfiguration