Skip to content

Commit 6fe6753

Browse files
adwk67claude
andcommitted
fix: restore kubernetes executor comment in validate_cluster
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
1 parent 0b2f83c commit 6fe6753

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

rust/operator-binary/src/airflow_controller.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -358,6 +358,8 @@ fn validate_cluster(
358358
) -> Result<ValidatedAirflowCluster> {
359359
let mut roles = HashMap::new();
360360

361+
// if the kubernetes executor is specified there will be no worker role as the pods
362+
// are provisioned by airflow as defined by the task (default: one pod per task)
361363
for role in AirflowRole::iter() {
362364
if let Some(resolved_role) = airflow.get_role(&role) {
363365
roles.insert(

0 commit comments

Comments
 (0)