diff --git a/posthog/temporal/batch_exports/postgres_batch_export.py b/posthog/temporal/batch_exports/postgres_batch_export.py
index ab46cadc6941f..5dbfc6faa4acf 100644
--- a/posthog/temporal/batch_exports/postgres_batch_export.py
+++ b/posthog/temporal/batch_exports/postgres_batch_export.py
@@ -359,7 +359,7 @@ async def flush_to_postgres():
                 if pg_file.tell() > 0:
                     await flush_to_postgres()
 
-        return pg_file.records_total
+            return pg_file.records_total
 
 
 @workflow.defn(name="postgres-export")