I want to be able to add arbitrary labels to an airflow worker pod. For example, I want to specify this in the task definition:
run_this = PythonOperator(
And have my worker pod have the label `test:label`.
My main use case for this is for auditing. We audit our kubernetes cluster by tags, attributing cost based on how much resources the pod uses.
I will make a PR.