diff --git a/src/fetch/dune.py b/src/fetch/dune.py
index 3b0aad44..52edfe8b 100644
--- a/src/fetch/dune.py
+++ b/src/fetch/dune.py
@@ -49,12 +49,17 @@ def _parameterized_query(
         return query_data.with_params(params)
 
     def _get_query_results(
-        self, query: Query, job_id: Optional[str] = None
+        self,
+        query: Query,
+        job_id: Optional[str] = None,
+        performance: str = "medium",
     ) -> list[dict[str, str]]:
         """Internally every dune query execution is routed through here."""
         log.info(f"Fetching {query.name} from query: {query}")
         if not job_id:
-            exec_result = self.dune.refresh(query, ping_frequency=15)
+            exec_result = self.dune.refresh(
+                query, performance=performance, ping_frequency=15
+            )
         else:
             exec_result = self.dune.get_result(job_id)
 
@@ -121,4 +126,5 @@ def get_period_slippage(self, job_id: Optional[str] = None) -> list[DuneRecord]:
                 ],
             ),
             job_id,
+            performance="large",
         )