diff --git a/library/Director/Import/PurgeStrategy/ImportRunBasedPurgeStrategy.php b/library/Director/Import/PurgeStrategy/ImportRunBasedPurgeStrategy.php
index 16f2a8cc..e8a7ae15 100644
--- a/library/Director/Import/PurgeStrategy/ImportRunBasedPurgeStrategy.php
+++ b/library/Director/Import/PurgeStrategy/ImportRunBasedPurgeStrategy.php
@@ -72,10 +72,12 @@ class ImportRunBasedPurgeStrategy extends PurgeStrategy
                 SyncUtils::extractVariableNames($pattern)
             );
 
-            $rows = $runA->fetchRows($columns, null, $result);
-            $result = array();
-            foreach ($rows as $row) {
-                $result[] = SyncUtils::fillVariables($pattern, $row);
+            foreach (array_chunk($result, 1000) as $keys) {
+                $rows = $runA->fetchRows($columns, null, $keys);
+                $result = array();
+                foreach ($rows as $row) {
+                    $result[] = SyncUtils::fillVariables($pattern, $row);
+                }
             }
         }