ISSUE #442

* Fix bug related with locking and `ComposedDatabaseOperation`.

Author: Sergio García Prado

packages/core/minos-microservice-common/minos/common/database/clients/abc.py

@@ -100,7 +100,7 @@ async def execute(self, operation: DatabaseOperation) -> None:
 
         if isinstance(operation, ComposedDatabaseOperation):
             for op in operation.operations:
-                await wait_for(self._execute(op), operation.timeout)
+                await wait_for(self.execute(op), operation.timeout)
         else:
             await wait_for(self._execute(operation), operation.timeout)
 

packages/core/minos-microservice-common/tests/test_common/test_database/test_clients/test_abc.py

@@ -133,13 +133,15 @@ async def test_execute(self):
         self.assertEqual([call(operation)], mock.call_args_list)
 
     async def test_execute_composed(self):
-        mock = AsyncMock()
         client = _DatabaseClient()
-        client._execute = mock
+        mock = AsyncMock(side_effect=client.execute)
+        client.execute = mock
         composed = ComposedDatabaseOperation([_DatabaseOperation(), _DatabaseOperation()])
         await client.execute(composed)
 
-        self.assertEqual([call(composed.operations[0]), call(composed.operations[1])], mock.call_args_list)
+        self.assertEqual(
+            [call(composed), call(composed.operations[0]), call(composed.operations[1])], mock.call_args_list
+        )
 
     async def test_execute_with_lock(self):
         op1 = _DatabaseOperation(lock="foo")