Skip to content

Commit 4ffc920

Browse files
author
Sergio García Prado
committed
ISSUE #?
* Fix bug related with the `DatabaseTransactionRepository` lookup.
1 parent 6c36311 commit 4ffc920

File tree

2 files changed

+11
-1
lines changed
  • packages/core/minos-microservice-transactions

2 files changed

+11
-1
lines changed

packages/core/minos-microservice-transactions/minos/transactions/repositories/database/impl.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ class DatabaseTransactionRepository(DatabaseMixin[TransactionDatabaseOperationFa
3131

3232
def __init__(self, *args, database_key: Optional[tuple[str]] = None, **kwargs):
3333
if database_key is None:
34-
database_key = ("aggregate", "transaction")
34+
database_key = ("transaction",)
3535
super().__init__(*args, database_key=database_key, **kwargs)
3636

3737
async def _setup(self) -> None:

packages/core/minos-microservice-transactions/tests/test_transactions/test_repositories/test_database.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
import unittest
22
from unittest.mock import (
33
patch,
4+
MagicMock,
5+
call,
46
)
57

68
from minos.common import (
@@ -29,6 +31,14 @@ class TestDatabaseTransactionRepository(TransactionsTestCase, TransactionReposit
2931
def build_transaction_repository(self) -> TransactionRepository:
3032
return DatabaseTransactionRepository.from_config(self.config)
3133

34+
def test_get_pool_call(self):
35+
get_pool_mock = MagicMock(side_effect=self.pool_factory.get_pool)
36+
self.pool_factory.get_pool = get_pool_mock
37+
38+
self.build_transaction_repository()
39+
40+
self.assertIn(call(type_="database", identifier="transaction"), get_pool_mock.call_args_list)
41+
3242
async def test_submit(self):
3343
with patch.object(
3444
DatabaseClient,

0 commit comments

Comments
 (0)