diff --git a/tests/test_slot_name.py b/tests/test_slot_name.py index fa330ee..18f8904 100644 --- a/tests/test_slot_name.py +++ b/tests/test_slot_name.py @@ -14,7 +14,7 @@ def setUp(self): def test_default_slot_name(self): # Test backward compatibility when slot name is not provided. config = self.default_config - tap = TapPostgres(config) + tap = TapPostgres(config=config) self.assertEqual( tap.config.get("replication_slot_name", "tappostgres"), "tappostgres" ) @@ -22,7 +22,7 @@ def test_default_slot_name(self): def test_custom_slot_name(self): # Test if the custom slot name is used. config = {**self.default_config, "replication_slot_name": "custom_slot"} - tap = TapPostgres(config) + tap = TapPostgres(config=config) self.assertEqual(tap.config["replication_slot_name"], "custom_slot") def test_multiple_slots(self): @@ -30,8 +30,8 @@ def test_multiple_slots(self): config_1 = {**self.default_config, "replication_slot_name": "slot_1"} config_2 = {**self.default_config, "replication_slot_name": "slot_2"} - tap_1 = TapPostgres(config_1) - tap_2 = TapPostgres(config_2) + tap_1 = TapPostgres(config=config_1) + tap_2 = TapPostgres(config=config_2) self.assertNotEqual( tap_1.config["replication_slot_name"], @@ -48,4 +48,4 @@ def test_invalid_slot_name(self): } with self.assertRaises(ValueError): - TapPostgres(invalid_config) + TapPostgres(config=invalid_config)