Commit request to database to prevent UniqueViolation due to parallel…

… requests processing.

[CLOUDDST-20061]

iib/web/models.py

@@ -257,6 +257,13 @@ def get_or_create(cls, pull_specification: str) -> Image:
         if not image:
             image = Image(pull_specification=pull_specification)
             db.session.add(image)
+            try:
+                db.session.commit()
+            except sqlalchemy.exc.IntegrityError:
+                current_app.logger.info(
+                    'Image pull specification is already in database. "%s"', pull_specification
+                )
+            image = cls.query.filter_by(pull_specification=pull_specification).first()
 
         return image
 
@@ -284,6 +291,11 @@ def get_or_create(cls, name: str) -> Operator:
         if not operator:
             operator = Operator(name=name)
             db.session.add(operator)
+            try:
+                db.session.commit()
+            except sqlalchemy.exc.IntegrityError:
+                current_app.logger.info('Operators is already in database. "%s"', name)
+            operator = cls.query.filter_by(name=name).first()
 
         return operator
 
@@ -1696,6 +1708,11 @@ def get_or_create(cls, username: str) -> User:
         if not user:
             user = User(username=username)
             db.session.add(user)
+            try:
+                db.session.commit()
+            except sqlalchemy.exc.IntegrityError:
+                current_app.logger.info('User is already in database. "%s"', username)
+            user = cls.query.filter_by(username=username).first()
 
         return user
 

tests/test_web/test_api_v1.py

@@ -1234,7 +1234,8 @@ def test_patch_request_add_success(
     }
 
     for bundle in bundles:
-        minimal_request_add.bundles.append(Image.get_or_create(bundle))
+        img = Image.get_or_create(bundle)
+        minimal_request_add.bundles.append(img)
     minimal_request_add.add_state('in_progress', 'Starting things up')
     db.session.commit()