feat: add driver features to Psycopg sync and async event channel configurations

cofin · cofin · commit 9387a500549f · 2025-12-22T03:15:26.000Z
diff --git a/tests/integration/test_adapters/test_psycopg/test_extensions/test_events.py b/tests/integration/test_adapters/test_psycopg/test_extensions/test_events.py
@@ -27,6 +27,7 @@ def test_psycopg_sync_event_channel_queue_fallback(tmp_path, postgres_service: P
     config = PsycopgSyncConfig(
         connection_config={"conninfo": _build_conninfo(postgres_service)},
         migration_config={"script_location": str(migrations_dir), "include_extensions": ["events"]},
+        driver_features={"events_backend": "table_queue", "enable_events": True},
     )
 
     commands = SyncMigrationCommands(config)
@@ -66,6 +67,7 @@ async def test_psycopg_async_event_channel_queue_fallback(tmp_path, postgres_ser
     config = PsycopgAsyncConfig(
         connection_config={"conninfo": _build_conninfo(postgres_service)},
         migration_config={"script_location": str(migrations_dir), "include_extensions": ["events"]},
+        driver_features={"events_backend": "table_queue", "enable_events": True},
     )
 
     commands = AsyncMigrationCommands(config)

Original file line number	Diff line number	Diff line change
`@@ -27,6 +27,7 @@ def test_psycopg_sync_event_channel_queue_fallback(tmp_path, postgres_service: P`
`27`	`27`	`config = PsycopgSyncConfig(`
`28`	`28`	`connection_config={"conninfo": _build_conninfo(postgres_service)},`
`29`	`29`	`migration_config={"script_location": str(migrations_dir), "include_extensions": ["events"]},`
	`30`	`+ driver_features={"events_backend": "table_queue", "enable_events": True},`
`30`	`31`	`)`
`31`	`32`
`32`	`33`	`commands = SyncMigrationCommands(config)`
`@@ -66,6 +67,7 @@ async def test_psycopg_async_event_channel_queue_fallback(tmp_path, postgres_ser`
`66`	`67`	`config = PsycopgAsyncConfig(`
`67`	`68`	`connection_config={"conninfo": _build_conninfo(postgres_service)},`
`68`	`69`	`migration_config={"script_location": str(migrations_dir), "include_extensions": ["events"]},`
	`70`	`+ driver_features={"events_backend": "table_queue", "enable_events": True},`
`69`	`71`	`)`
`70`	`72`
`71`	`73`	`commands = AsyncMigrationCommands(config)`