diff --git a/src/Task/AbstractProcessTask.php b/src/Task/AbstractProcessTask.php
index 8cc9934b..9685529c 100644
--- a/src/Task/AbstractProcessTask.php
+++ b/src/Task/AbstractProcessTask.php
@@ -133,7 +133,7 @@ protected function process(PipelinePayloadInterface $initialPayload): void
             /** @var Result $queryResult */
             $queryResult = $query->executeQuery();
 
-            while ($results = $queryResult->fetchAll()) {
+            while ($results = $queryResult->fetchAllAssociative()) {
                 $ids = [];
                 foreach ($results as $result) {
                     $ids[] = $result['id'];
diff --git a/src/Task/Asset/BatchAssetTask.php b/src/Task/Asset/BatchAssetTask.php
index 77578870..a17127ef 100644
--- a/src/Task/Asset/BatchAssetTask.php
+++ b/src/Task/Asset/BatchAssetTask.php
@@ -34,7 +34,7 @@ public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInte
         /** @var Result $queryResult */
         $queryResult = $query->executeQuery();
 
-        while ($results = $queryResult->fetchAll()) {
+        while ($results = $queryResult->fetchAllAssociative()) {
             foreach ($results as $result) {
                 try {
                     $resource = \json_decode($result['values'], true, 512, \JSON_THROW_ON_ERROR);
diff --git a/src/Task/AssociationType/BatchAssociationTypesTask.php b/src/Task/AssociationType/BatchAssociationTypesTask.php
index 8bc48e60..47752d8c 100644
--- a/src/Task/AssociationType/BatchAssociationTypesTask.php
+++ b/src/Task/AssociationType/BatchAssociationTypesTask.php
@@ -55,7 +55,7 @@ public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInte
             /** @var Result $queryResult */
             $queryResult = $query->executeQuery();
 
-            while ($results = $queryResult->fetchAll()) {
+            while ($results = $queryResult->fetchAllAssociative()) {
                 foreach ($results as $result) {
                     /** @var array{code: string, labels: array} $resource */
                     $resource = json_decode($result['values'], true, 512, \JSON_THROW_ON_ERROR);
diff --git a/src/Task/Attribute/BatchAttributesTask.php b/src/Task/Attribute/BatchAttributesTask.php
index 0a58343b..fa2eca29 100644
--- a/src/Task/Attribute/BatchAttributesTask.php
+++ b/src/Task/Attribute/BatchAttributesTask.php
@@ -64,7 +64,7 @@ public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInte
             $queryResult = $query->executeQuery();
 
             $variationAxes = array_unique($this->getVariationAxes($payload));
-            while ($results = $queryResult->fetchAll()) {
+            while ($results = $queryResult->fetchAllAssociative()) {
                 foreach ($results as $result) {
                     $resource = json_decode($result['values'], true, 512, \JSON_THROW_ON_ERROR);
 
diff --git a/src/Task/Product/BatchProductsTask.php b/src/Task/Product/BatchProductsTask.php
index 329e2389..7a84f03a 100644
--- a/src/Task/Product/BatchProductsTask.php
+++ b/src/Task/Product/BatchProductsTask.php
@@ -33,7 +33,7 @@ public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInte
         /** @var Result $queryResult */
         $queryResult = $query->executeQuery();
 
-        while ($results = $queryResult->fetchAll()) {
+        while ($results = $queryResult->fetchAllAssociative()) {
             foreach ($results as $result) {
                 try {
                     /** @var array{identifier: string,parent: string|null} $resource */
diff --git a/src/Task/ProductModel/BatchProductModelTask.php b/src/Task/ProductModel/BatchProductModelTask.php
index 49f8ca32..4e18110d 100644
--- a/src/Task/ProductModel/BatchProductModelTask.php
+++ b/src/Task/ProductModel/BatchProductModelTask.php
@@ -60,7 +60,7 @@ public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInte
         /** @var Result $queryResult */
         $queryResult = $query->executeQuery();
 
-        while ($results = $queryResult->fetchAll()) {
+        while ($results = $queryResult->fetchAllAssociative()) {
             foreach ($results as $result) {
                 /** @var array $resource */
                 $resource = json_decode($result['values'], true);