[Python] AttributeError: 'QueuedLocalWorker' object has no attribute 'wrapper' when using...

I'm getting this error when I try to run Airflow 2.6.3 with LocalExecutor: AttributeError: 'QueuedLocalWorker' object has no attribute 'wrapper' I've double-checked my airflow.cfg and confirmed I have executor = LocalExecutor set properly. The error occurs when trying to start the scheduler. I initially tried setting up a Celery cluster but decided to switch to LocalExecutor for simplicity. I'm wondering if there might be some lingering Celery configurations causing conflicts. Has anyone encountered this specific error with LocalExecutor in Airflow 2.6.3? Any suggestions on how to resolve it? My environment:

Apache Airflow 2.6.3 Python 3.11

Continue reading...