@@ -286,7 +286,7 @@ def _do_update_cluster(self, cluster_id, values):
286
286
query = model_query (models .Cluster , session = session )
287
287
query = add_identity_filter (query , cluster_id )
288
288
try :
289
- ref = query .with_lockmode ( 'update' ).one ()
289
+ ref = query .with_for_update ( ).one ()
290
290
except NoResultFound :
291
291
raise exception .ClusterNotFound (cluster = cluster_id )
292
292
@@ -344,7 +344,7 @@ def get_cluster_template_by_id(self, context, cluster_template_id):
344
344
query = self ._add_tenant_filters (context , query )
345
345
public_q = model_query (models .ClusterTemplate ).filter_by (public = True )
346
346
query = query .union (public_q )
347
- query = query .filter_by (id = cluster_template_id )
347
+ query = query .filter_by (cluster_template_id = cluster_template_id )
348
348
try :
349
349
return query .one ()
350
350
except NoResultFound :
@@ -356,7 +356,7 @@ def get_cluster_template_by_uuid(self, context, cluster_template_uuid):
356
356
query = self ._add_tenant_filters (context , query )
357
357
public_q = model_query (models .ClusterTemplate ).filter_by (public = True )
358
358
query = query .union (public_q )
359
- query = query .filter_by (uuid = cluster_template_uuid )
359
+ query = query .filter_by (cluster_template_uuid = cluster_template_uuid )
360
360
try :
361
361
return query .one ()
362
362
except NoResultFound :
@@ -368,7 +368,7 @@ def get_cluster_template_by_name(self, context, cluster_template_name):
368
368
query = self ._add_tenant_filters (context , query )
369
369
public_q = model_query (models .ClusterTemplate ).filter_by (public = True )
370
370
query = query .union (public_q )
371
- query = query .filter_by (name = cluster_template_name )
371
+ query = query .filter_by (cluster_template_name = cluster_template_name )
372
372
try :
373
373
return query .one ()
374
374
except MultipleResultsFound :
@@ -427,7 +427,7 @@ def _do_update_cluster_template(self, cluster_template_id, values):
427
427
query = model_query (models .ClusterTemplate , session = session )
428
428
query = add_identity_filter (query , cluster_template_id )
429
429
try :
430
- ref = query .with_lockmode ( 'update' ).one ()
430
+ ref = query .with_for_update ( ).one ()
431
431
except NoResultFound :
432
432
raise exception .ClusterTemplateNotFound (
433
433
clustertemplate = cluster_template_id )
@@ -497,7 +497,7 @@ def _do_update_x509keypair(self, x509keypair_id, values):
497
497
query = model_query (models .X509KeyPair , session = session )
498
498
query = add_identity_filter (query , x509keypair_id )
499
499
try :
500
- ref = query .with_lockmode ( 'update' ).one ()
500
+ ref = query .with_for_update ( ).one ()
501
501
except NoResultFound :
502
502
raise exception .X509KeyPairNotFound (x509keypair = x509keypair_id )
503
503
@@ -539,7 +539,7 @@ def update_magnum_service(self, magnum_service_id, values):
539
539
query = model_query (models .MagnumService , session = session )
540
540
query = add_identity_filter (query , magnum_service_id )
541
541
try :
542
- ref = query .with_lockmode ( 'update' ).one ()
542
+ ref = query .with_for_update ( ).one ()
543
543
except NoResultFound :
544
544
raise exception .MagnumServiceNotFound (
545
545
magnum_service_id = magnum_service_id )
@@ -623,7 +623,7 @@ def update_quota(self, project_id, values):
623
623
try :
624
624
query = query .filter_by (project_id = project_id ).filter_by (
625
625
resource = resource )
626
- ref = query .with_lockmode ( 'update' ).one ()
626
+ ref = query .with_for_update ( ).one ()
627
627
except NoResultFound :
628
628
msg = (_ ('project_id %(project_id)s resource %(resource)s.' ) %
629
629
{'project_id' : project_id , 'resource' : resource })
@@ -775,7 +775,7 @@ def _do_update_federation(self, federation_id, values):
775
775
query = model_query (models .Federation , session = session )
776
776
query = add_identity_filter (query , federation_id )
777
777
try :
778
- ref = query .with_lockmode ( 'update' ).one ()
778
+ ref = query .with_for_update ( ).one ()
779
779
except NoResultFound :
780
780
raise exception .FederationNotFound (federation = federation_id )
781
781
@@ -837,7 +837,7 @@ def _do_update_nodegroup(self, cluster_id, nodegroup_id, values):
837
837
query = add_identity_filter (query , nodegroup_id )
838
838
query = query .filter_by (cluster_id = cluster_id )
839
839
try :
840
- ref = query .with_lockmode ( 'update' ).one ()
840
+ ref = query .with_for_update ( ).one ()
841
841
except NoResultFound :
842
842
raise exception .NodeGroupNotFound (nodegroup = nodegroup_id )
843
843
0 commit comments