ftakelait opened a new pull request, #60033: URL: https://github.com/apache/airflow/pull/60033
## Summary Migrates `conf` imports in the Celery provider from `airflow.configuration` to `airflow.providers.common.compat.sdk` for Airflow 3.x SDK compatibility. ## Changes Made ### Import Migration (9 files) - `celery_executor.py` - `celery_executor_utils.py` (2 imports) - `celery_kubernetes_executor.py` - `celery_command.py` - `default_celery.py` - Test files (4 files) ### Fallback Parameters Added Added `fallback` parameters to `conf.get()` calls that execute at module import time: | File | Config Key | Fallback | |------|-----------|----------| | `celery_executor.py` | `FLOWER_HOST` | `"0.0.0.0"` | | `celery_executor.py` | `FLOWER_PORT` | `5555` | | `celery_executor.py` | `FLOWER_URL_PREFIX` | `""` | | `celery_executor.py` | `FLOWER_BASIC_AUTH` | `""` | | `celery_executor.py` | `DEFAULT_QUEUE` | `"default"` | | `celery_executor.py` | `worker_concurrency` | `16` | | `celery_executor.py` | `SYNC_PARALLELISM` | `0` | | `celery_executor.py` | `task_publish_max_retries` | `3` | | `celery_executor_utils.py` | `operation_timeout` | `1.0` | | `celery_executor_utils.py` | `CELERY_APP_NAME` | `"airflow.executors.celery_executor"` | | `default_celery.py` | `SSL_ACTIVE` | `False` | ## Why fallbacks are needed? The SDK `conf.get()` is stricter than `airflow.configuration.conf.get()` - it raises `AirflowConfigException` when a key is not found instead of returning `None`. This was causing test collection failures when config keys were accessed at module import time before provider configuration was loaded. Part of #60000 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
