@@ -148,18 +148,20 @@ class UpdateClusterRequest(_message.Message):
148148 class UpdateClusterResources (_message .Message ):
149149 __slots__ = ("airflow" ,)
150150 class Airflow (_message .Message ):
151- __slots__ = ("max_worker_count" , "min_worker_count" , "worker_concurrency" , "worker_disk_size" , "worker_preset" )
151+ __slots__ = ("max_worker_count" , "min_worker_count" , "worker_concurrency" , "worker_disk_size" , "worker_preset" , "environment_flavor" )
152152 MAX_WORKER_COUNT_FIELD_NUMBER : _ClassVar [int ]
153153 MIN_WORKER_COUNT_FIELD_NUMBER : _ClassVar [int ]
154154 WORKER_CONCURRENCY_FIELD_NUMBER : _ClassVar [int ]
155155 WORKER_DISK_SIZE_FIELD_NUMBER : _ClassVar [int ]
156156 WORKER_PRESET_FIELD_NUMBER : _ClassVar [int ]
157+ ENVIRONMENT_FLAVOR_FIELD_NUMBER : _ClassVar [int ]
157158 max_worker_count : _wrappers_pb2 .Int64Value
158159 min_worker_count : _wrappers_pb2 .Int64Value
159160 worker_concurrency : _wrappers_pb2 .Int64Value
160161 worker_disk_size : _wrappers_pb2 .Int64Value
161162 worker_preset : _wrappers_pb2 .StringValue
162- def __init__ (self , max_worker_count : _Optional [_Union [_wrappers_pb2 .Int64Value , _Mapping ]] = ..., min_worker_count : _Optional [_Union [_wrappers_pb2 .Int64Value , _Mapping ]] = ..., worker_concurrency : _Optional [_Union [_wrappers_pb2 .Int64Value , _Mapping ]] = ..., worker_disk_size : _Optional [_Union [_wrappers_pb2 .Int64Value , _Mapping ]] = ..., worker_preset : _Optional [_Union [_wrappers_pb2 .StringValue , _Mapping ]] = ...) -> None : ...
163+ environment_flavor : _wrappers_pb2 .StringValue
164+ def __init__ (self , max_worker_count : _Optional [_Union [_wrappers_pb2 .Int64Value , _Mapping ]] = ..., min_worker_count : _Optional [_Union [_wrappers_pb2 .Int64Value , _Mapping ]] = ..., worker_concurrency : _Optional [_Union [_wrappers_pb2 .Int64Value , _Mapping ]] = ..., worker_disk_size : _Optional [_Union [_wrappers_pb2 .Int64Value , _Mapping ]] = ..., worker_preset : _Optional [_Union [_wrappers_pb2 .StringValue , _Mapping ]] = ..., environment_flavor : _Optional [_Union [_wrappers_pb2 .StringValue , _Mapping ]] = ...) -> None : ...
163165 AIRFLOW_FIELD_NUMBER : _ClassVar [int ]
164166 airflow : UpdateClusterRequest .UpdateClusterResources .Airflow
165167 def __init__ (self , airflow : _Optional [_Union [UpdateClusterRequest .UpdateClusterResources .Airflow , _Mapping ]] = ...) -> None : ...
0 commit comments