diff --git a/posthog/temporal/batch_exports/batch_exports.py b/posthog/temporal/batch_exports/batch_exports.py index bfb2325715fc1..88cf9e32f274f 100644 --- a/posthog/temporal/batch_exports/batch_exports.py +++ b/posthog/temporal/batch_exports/batch_exports.py @@ -1,4 +1,3 @@ -import abc import collections.abc import dataclasses import datetime as dt @@ -7,7 +6,6 @@ from string import Template import pyarrow as pa -import pyarrow.parquet as pq from asgiref.sync import sync_to_async from django.conf import settings from temporalio import activity, exceptions, workflow diff --git a/posthog/temporal/batch_exports/s3_batch_export.py b/posthog/temporal/batch_exports/s3_batch_export.py index 26a711e8acedc..996fccdd94aca 100644 --- a/posthog/temporal/batch_exports/s3_batch_export.py +++ b/posthog/temporal/batch_exports/s3_batch_export.py @@ -20,10 +20,6 @@ from posthog.temporal.batch_exports.base import PostHogWorkflow from posthog.temporal.batch_exports.batch_exports import ( CreateBatchExportRunInputs, - FlushCallable, - JSONLBatchExportWriter, - ParquetBatchExportWriter, - UnsupportedFileFormatError, UpdateBatchExportRunStatusInputs, create_export_run, default_fields,