rickyzhang82 commented on issue #41525:
URL: https://github.com/apache/airflow/issues/41525#issuecomment-2546776507
@potiuk ,
I checked out the tag: `2.10.2` from airflow Git repo (commit
35087d7d10714130cc3e9e9730e34b07fc56938d) and still ran into the same attribute
error:
```
File
"/home/Ricky/sas-u-home/rizhan/repo/github/airflow/airflow/jobs/scheduler_job_runner.py",
line 718, in <listcomp>
num_occupied_slots = sum([executor.slots_occupied for executor in
self.job.executors])
AttributeError: 'SasKubernetesCeleryExecutor' object has no attribute
'slots_occupied'
```
However, we didn't see the same issue from Airflow in our production build
which pip from PyPi with `2.10.2` tag.
The source code from PyPi is not the **same** even though pointing to
`2.10.2`
The one from PyPi --
airflow/providers/celery/executors/celery_kubernetes_executor.py has the fix
but it is not in the `2.10.2` release tag
```
119 @property
120 def slots_occupied(self):
121 """Number of tasks this executor instance is currently
managing."""
122 return len(self.running) + len(self.queued_tasks)
```
I wonder why?
--
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]
