feat: Heartbeating and asyncio for BigQuery batch exports

[tomasfarias]

Problem

We have refactored the following destinations to use async calls for blocking io:

• Postgres and Redshift (refactor: Postgres (+ Redshift) batch exports now async #18631)
• Snowflake (refactor: Snowflake batch export #18427)
• S3 (refactor(s3-batch-exports): Swap to asyncio s3 client  #17673)

This is the final one, BigQuery.

Changes

• Wrap blocking IO in asyncio.to_thread
• Add heartbeatting.

👉 Stay up-to-date with PostHog coding conventions for a smoother review.

How did you test this code?

Manual tests:

DEBUG=1 pytest posthog/temporal/tests/batch_exports/test_bigquery_batch_export_workflow.py -vv 
===================================================== test session starts =====================================================
platform linux -- Python 3.10.10, pytest-7.4.0, pluggy-0.13.1 -- ./.direnv/python-3.10.10/bin/python
cachedir: .pytest_cache
django: settings: posthog.settings (from ini)
rootdir: .
configfile: pytest.ini
plugins: asyncio-0.21.1, icdiff-0.6, flaky-3.7.0, env-0.8.2, Faker-17.5.0, syrupy-1.7.4, mock-3.11.1, split-0.8.1, django-4.5.2, cov-4.1.0
asyncio: mode=strict
collected 8 items                                                                                                             

posthog/temporal/tests/batch_exports/test_bigquery_batch_export_workflow.py::test_insert_into_bigquery_activity_inserts_data_into_bigquery_table[None] PASSED [ 12%]
posthog/temporal/tests/batch_exports/test_bigquery_batch_export_workflow.py::test_insert_into_bigquery_activity_inserts_data_into_bigquery_table[exclude_events1] PASSED [ 25%]
posthog/temporal/tests/batch_exports/test_bigquery_batch_export_workflow.py::test_bigquery_export_workflow[None-hour] PASSED [ 37%]
posthog/temporal/tests/batch_exports/test_bigquery_batch_export_workflow.py::test_bigquery_export_workflow[None-day] PASSED [ 50%]
posthog/temporal/tests/batch_exports/test_bigquery_batch_export_workflow.py::test_bigquery_export_workflow[exclude_events1-hour] PASSED [ 62%]
posthog/temporal/tests/batch_exports/test_bigquery_batch_export_workflow.py::test_bigquery_export_workflow[exclude_events1-day] PASSED [ 75%]
posthog/temporal/tests/batch_exports/test_bigquery_batch_export_workflow.py::test_bigquery_export_workflow_handles_insert_activity_errors PASSED [ 87%]
posthog/temporal/tests/batch_exports/test_bigquery_batch_export_workflow.py::test_bigquery_export_workflow_handles_cancellation PASSED [100%]

--------------------------------------------------- snapshot report summary ---------------------------------------------------

===================================================== 8 passed in 57.52s ======================================================

[github-actions]

Size Change: 0 B

Total Size: 2.01 MB

ℹ️ View Unchanged

Filename	Size
frontend/dist/toolbar.js	2.01 MB

_{compressed-size-action}

[sentry-io]

Suspect Issues

This pull request was deployed and Sentry observed the following issues:

• ‼️ Forbidden: 403 Quota exceeded: Your table exceeded quota for imports or query appends per table. For more in... google.api_core.future.polling in result View Issue
• ‼️ RefreshError: ('invalid_grant: Invalid grant: account not found', {'error': 'invalid_grant', 'error_description... google.oauth2._client in _handle_error_response View Issue

_{Did you find this useful? React with a 👍 or 👎}