Given that GCP composer is running with GKE/GCE, is it auto scaling? Now I have 3 nodes in the cluster to support say, 100 DAGs.
Later, if I have about 300 DAGs, will it scale up itself (w/ celery workers)?
Given that GCP composer is running with GKE/GCE, is it auto scaling? Now I have 3 nodes in the cluster to support say, 100 DAGs.
Later, if I have about 300 DAGs, will it scale up itself (w/ celery workers)?
We currently don't support auto-scaling but it's on our roadmap. You could however manually scale up/down the GKE cluster by updating the nodeCount value.
I just published an article showing how to enable autoscale in its underlying kubernetes https://link.medium.com/AMUlwUIkD0.
Basically:
Enable autoscale on the node level
Apply HorizontalPodAutoscaler to airflow-worker deployment
Increase some airflow config parameter to remove the bottleneck
This has been tested in composer-1.7.2 and composer-1.7.5 but might be applicable to other version as well
Do check it out