Add validation for cluster label (#72)

flyteorg · Feb 28, 2020 · cc9917e · cc9917e
1 parent 15d1fa0
commit cc9917e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/manager/impl/validation/attributes_validator.go b/pkg/manager/impl/validation/attributes_validator.go
@@ -21,6 +21,8 @@ func validateMatchingAttributes(attributes *admin.MatchingAttributes, identifier
 		return admin.MatchableResource_CLUSTER_RESOURCE, nil
 	} else if attributes.GetExecutionQueueAttributes() != nil {
 		return admin.MatchableResource_EXECUTION_QUEUE, nil
+	} else if attributes.GetExecutionClusterLabel() != nil {
+		return admin.MatchableResource_EXECUTION_CLUSTER_LABEL, nil
 	}
 	return defaultMatchableResource, errors.NewFlyteAdminErrorf(codes.InvalidArgument,
 		"Unrecognized matching attributes type for request %s", identifier)