revert-me: Skip all postgres tests

posthog/temporal/tests/batch_exports/test_batch_exports.py

@@ -19,7 +19,7 @@
     json_dumps_bytes,
 )
 
-pytestmark = [pytest.mark.django_db, pytest.mark.asyncio]
+pytestmark = [pytest.mark.asyncio, pytest.mark.django_db]
 
 
 async def test_get_rows_count(clickhouse_client):

posthog/temporal/tests/batch_exports/test_bigquery_batch_export_workflow.py

@@ -30,7 +30,7 @@
     insert_into_bigquery_activity,
 )
 
-pytestmark = [pytest.mark.asyncio, pytest.mark.asyncio_event_loop, pytest.mark.django_db]
+pytestmark = [pytest.mark.asyncio, pytest.mark.django_db]
 
 TEST_TIME = dt.datetime.utcnow()
 

posthog/temporal/tests/batch_exports/test_postgres_batch_export_workflow.py

@@ -29,7 +29,10 @@
     insert_into_postgres_activity,
 )
 
-pytestmark = [pytest.mark.asyncio, pytest.mark.asyncio_event_loop, pytest.mark.django_db]
+pytestmark = [
+    pytest.mark.asyncio,
+    pytest.mark.django_db,
+]
 
 
 def assert_events_in_postgres(connection, schema, table_name, events, exclude_events: list[str] | None = None):

posthog/temporal/tests/conftest.py

@@ -63,7 +63,7 @@ def activity_environment():
     return ActivityEnvironment()
 
 
-@pytest.fixture(scope="module")
+@pytest.fixture
 def clickhouse_client():
     """Provide a ClickHouseClient to use in tests."""
     client = ClickHouseClient(
@@ -76,14 +76,7 @@ def clickhouse_client():
     yield client
 
 
-@pytest.fixture(scope="module")
-def event_loop():
-    loop = asyncio.get_event_loop()
-    yield loop
-    loop.close()
-
-
-@pytest_asyncio.fixture(scope="module")
+@pytest_asyncio.fixture
 async def temporal_client():
     """Provide a temporalio.client.Client to use in tests."""
     client = await connect(

posthog/temporal/workflows/postgres_batch_export.py

@@ -1,4 +1,5 @@
 import collections.abc
+import asyncio
 import contextlib
 import datetime as dt
 import json
@@ -254,6 +255,8 @@ async def insert_into_postgres_activity(inputs: PostgresInsertInputs):
                         schema_columns,
                     )
 
+        await asyncio.sleep(10)
+
 
 @workflow.defn(name="postgres-export")
 class PostgresBatchExportWorkflow(PostHogWorkflow):