Bitnami/containers
2
0
Fork 0
mirror of https://github.com/bitnami/containers.git synced 2026-02-10 03:15:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

[bitnami/airflow] Allow multiple executors with CeleryExecutor (#84530)

Browse Source 
Allow multiple executors with CeleryExecutor

Signed-off-by: Julien Del Piccolo <julien@del-piccolo.com>
This commit is contained in:
Julien Del Piccolo
2025-08-19 12:23:55 +02:00
committed by GitHub
parent 481b8b2c16
commit 546885dd49
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
bitnami/airflow/3/debian-12/rootfs/opt/bitnami/scripts/libairflow.sh
View File

@@ -111,7 +111,7 @@ airflow_validate() {
check_resolved_hostname "$AIRFLOW_DATABASE_HOST"
check_positive_value AIRFLOW_DATABASE_PORT_NUMBER
check_positive_value REDIS_PORT_NUMBER
if [[ "$AIRFLOW_EXECUTOR" == "CeleryExecutor" || "$AIRFLOW_EXECUTOR" == "CeleryKubernetesExecutor" ]]; then
if [[ "$AIRFLOW_EXECUTOR" =~ "CeleryExecutor" || "$AIRFLOW_EXECUTOR" == "CeleryKubernetesExecutor" ]]; then
check_empty_value "REDIS_HOST"
check_resolved_hostname "$REDIS_HOST"
fi
@@ -227,7 +227,7 @@ airflow_initialize() {
airflow_wait_for_db_migrations
info "Waiting for admin user to be created"
airflow_wait_for_admin_user
if [[ "$AIRFLOW_EXECUTOR" == "CeleryExecutor" || "$AIRFLOW_EXECUTOR" == "CeleryKubernetesExecutor" ]]; then
if [[ "$AIRFLOW_EXECUTOR" =~ "CeleryExecutor" || "$AIRFLOW_EXECUTOR" == "CeleryKubernetesExecutor" ]]; then
wait-for-port --host "$REDIS_HOST" "$REDIS_PORT_NUMBER"
fi
;;
@@ -347,7 +347,7 @@ airflow_generate_config() {
# Configure Airflow executor
airflow_conf_set "core" "executor" "$AIRFLOW_EXECUTOR"
[[ "$AIRFLOW_EXECUTOR" == "CeleryExecutor" || "$AIRFLOW_EXECUTOR" == "CeleryKubernetesExecutor" ]] && airflow_configure_celery_executor
[[ "$AIRFLOW_EXECUTOR" =~ "CeleryExecutor" || "$AIRFLOW_EXECUTOR" == "CeleryKubernetesExecutor" ]] && airflow_configure_celery_executor
true # Avoid the function to fail due to the check above
}