Fix of Asynchronous opetations status issue

app/code/Magento/AsynchronousOperations/etc/db_schema.xml

@@ -34,7 +34,7 @@
  <table name="magento_operation" resource="default" engine="innodb" comment="Operation entity">
  <column xsi:type="int" name="id" padding="10" unsigned="true" nullable="false" identity="true"
  comment="Operation ID"/>
- <column xsi:type="int" name="operation_key" padding="10" unsigned="true" nullable="false"
+ <column xsi:type="int" name="operation_key" padding="10" unsigned="true" nullable="true"
  comment="Operation Key"/>
  <column xsi:type="varbinary" name="bulk_uuid" nullable="true" length="39" comment="Related Bulk UUID"/>
  <column xsi:type="varchar" name="topic_name" nullable="true" length="255"

dev/tests/integration/testsuite/Magento/Catalog/Model/Attribute/Backend/ConsumerTest.php

@@ -0,0 +1,163 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+
+declare(strict_types=1);
+
+namespace Magento\Catalog\Model\Attribute\Backend;
+
+use Magento\AsynchronousOperations\Api\Data\OperationInterface;
+use Magento\AsynchronousOperations\Api\Data\OperationInterfaceFactory;
+use Magento\AsynchronousOperations\Model\BulkManagement;
+use Magento\AsynchronousOperations\Model\BulkStatus;
+use Magento\Framework\MessageQueue\BulkPublisherInterface;
+use Magento\Framework\ObjectManagerInterface;
+use Magento\TestFramework\Helper\Bootstrap;
+use PHPUnit\Framework\TestCase;
+use Magento\Catalog\Helper\Product;
+use Magento\Catalog\Model\Indexer\Product\Flat\Processor as FlatProcessor;
+use Magento\Catalog\Model\Indexer\Product\Price\Processor as PriceProcessor;
+use Magento\Framework\Bulk\OperationManagementInterface;
+use Magento\Catalog\Model\Product\Action;
+use Psr\Log\LoggerInterface;
+use Magento\Framework\Serialize\SerializerInterface;
+use Magento\Framework\EntityManager\EntityManager;
+use Magento\Catalog\Model\Attribute\Backend\Consumer;
+
+/**
+ * Test for Mysql Consumer execution
+ *
+ * @SuppressWarnings(PHPMD.CouplingBetweenObjects)
+ */
+class ConsumerTest extends TestCase
+{
+ const BULK_UUID = '5a12c1bd-a8b5-41d4-8c00-3f5bcaa6d3c8';
+
+ /**
+ * @var Consumer
+ */
+ private $model;
+
+ /**
+ * @var \PHPUnit\Framework\MockObject\MockObject
+ */
+ private $publisherMock;
+
+ /**
+ * @var BulkManagement
+ */
+ private $bulkManagement;
+
+ /**
+ * @var BulkStatus
+ */
+ private $bulkStatus;
+
+ /**
+ * @var ObjectManagerInterface
+ */
+ private $objectManager;
+
+ /**
+ * @var SerializerInterface
+ */
+ private $serializer;
+
+ /**
+ * @inheritdoc
+ */
+ protected function setUp(): void
+ {
+ $this->objectManager = Bootstrap::getObjectManager();
+ $this->publisherMock = $this->getMockForAbstractClass(BulkPublisherInterface::class);
+
+ $this->bulkManagement = $this->objectManager->create(
+ BulkManagement::class,
+ [
+ 'publisher' => $this->publisherMock
+ ]
+ );
+ $this->bulkStatus = $this->objectManager->get(BulkStatus::class);
+ $catalogProductMock = $this->createMock(Product::class);
+ $productFlatIndexerProcessorMock = $this->createMock(
+ FlatProcessor::class
+ );
+ $productPriceIndexerProcessorMock = $this->createMock(
+ PriceProcessor::class
+ );
+ $operationManagementMock = $this->createMock(
+ OperationManagementInterface::class
+ );
+ $actionMock = $this->createMock(Action::class);
+ $loggerMock = $this->createMock(LoggerInterface::class);
+ $this->serializer = $this->objectManager->get(SerializerInterface::class);
+ $entityManager = $this->objectManager->get(EntityManager::class);
+ $this->model = $this->objectManager->create(
+ Consumer::class,
+ [
+ 'catalogProduct' => $catalogProductMock,
+ 'productFlatIndexerProcessor' => $productFlatIndexerProcessorMock,
+ 'productPriceIndexerProcessor' => $productPriceIndexerProcessorMock,
+ 'operationManagement' => $operationManagementMock,
+ 'action' => $actionMock,
+ 'logger' => $loggerMock,
+ 'serializer' => $this->serializer,
+ 'entityManager' => $entityManager
+ ]
+ );
+
+ parent::setUp();
+ }
+
+ /**
+ * Testing saving bulk operation during processing operation by attribute backend consumer
+ */
+ public function testSaveOperationDuringProcess()
+ {
+ $operation = $this->prepareUpdateAttributesBulkAndOperation();
+ try {
+ $this->model->process($operation);
+ } catch (\Exception $e) {
+ $this->fail(sprintf('Operation save process failed.: %s', $e->getMessage()));
+ }
+ $operationStatus = $operation->getStatus();
+ $this->assertEquals(
+ 1,
+ $this->bulkStatus->getOperationsCountByBulkIdAndStatus(self::BULK_UUID, $operationStatus)
+ );
+ }
+
+ /**
+ * Schedules test bulk and returns operation
+ * @return OperationInterface
+ */
+ private function prepareUpdateAttributesBulkAndOperation(): OperationInterface
+ {
+ // general bulk information
+ $bulkUuid = self::BULK_UUID;
+ $bulkDescription = 'Update attributes for 2 selected products';
+ $topicName = 'product_action_attribute.update';
+ $userId = 1;
+ /** @var OperationInterfaceFactory $operationFactory */
+ $operationFactory = $this->objectManager->get(OperationInterfaceFactory::class);
+ $operation = $operationFactory->create();
+ $operation->setBulkUuid($bulkUuid)
+ ->setTopicName($topicName)
+ ->setSerializedData($this->serializer->serialize(
+ ['product_ids' => [1,3], 'attributes' => [], 'store_id' => '0']
+ ));
+ $this->bulkManagement->scheduleBulk($bulkUuid, [$operation], $bulkDescription, $userId);
+ return $operation;
+ }
+
+ /**
+ * Clear created bulk and operation
+ */
+ protected function tearDown(): void
+ {
+ $this->bulkManagement->deleteBulk(self::BULK_UUID);
+ parent::tearDown();
+ }
+}