Remove rw aggregation not supported in a transaction

mongodb · Jun 26, 2023 · 28cc1f5 · 28cc1f5
1 parent 52340de
commit 28cc1f5
Showing 1 changed file with 3 additions and 11 deletions.
diff --git a/tests/Collection/CollectionFunctionalTest.php b/tests/Collection/CollectionFunctionalTest.php
@@ -7,7 +7,6 @@
 use MongoDB\Collection;
 use MongoDB\Database;
 use MongoDB\Driver\BulkWrite;
-use MongoDB\Driver\Exception\CommandException;
 use MongoDB\Driver\ReadConcern;
 use MongoDB\Driver\ReadPreference;
 use MongoDB\Driver\WriteConcern;
@@ -457,6 +456,7 @@ function ($collection, $session, $options = []): void {
                 }, 'r',
             ],
 
+            /* Disabled, as write aggregations are not supported in transactions
             'read-write aggregate' => [
                 function ($collection, $session, $options = []): void {
                     $collection->aggregate(
@@ -468,6 +468,7 @@ function ($collection, $session, $options = []): void {
                     );
                 }, 'rw',
             ],
+            */
 
             'bulkWrite insertOne' => [
                 function ($collection, $session, $options = []): void {
@@ -748,16 +749,7 @@ public function testMethodDoesNotInheritReadWriteConcernInTransaction(Closure $m
 
         (new CommandObserver())->observe(
             function () use ($method, $collection, $session): void {
-                try {
-                    call_user_func($method, $collection, $session);
-                } catch (CommandException $exception) {
-                    // Write aggregates are not supported in transactions
-                    if ($exception->getResultDocument()->codeName === 'OperationNotSupportedInTransaction') {
-                        $this->markTestSkipped('OperationNotSupportedInTransaction: ' . $exception->getMessage());
-                    }
-
-                    throw $exception;
-                }
+                call_user_func($method, $collection, $session);
             },
             function (array $event): void {
                 $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());