diff --git a/python/gigl/src/data_preprocessor/lib/ingest/bigquery.py b/python/gigl/src/data_preprocessor/lib/ingest/bigquery.py
index 46ec168ab..616e00401 100644
--- a/python/gigl/src/data_preprocessor/lib/ingest/bigquery.py
+++ b/python/gigl/src/data_preprocessor/lib/ingest/bigquery.py
@@ -17,7 +17,7 @@ def _get_bigquery_ptransform(
         InstanceDictPTransform,
         beam.io.ReadFromBigQuery(
             table=table_name,
-            method=beam.io.ReadFromBigQuery.Method.EXPORT,  # type: ignore
+            method=beam.io.ReadFromBigQuery.Method.DIRECT_READ,  # type: ignore
             *args,
             **kwargs,
         ),