Skip to content

Commit 7a37a0a

Browse files
committed
Support createEntities test runner operation
1 parent c1eec89 commit 7a37a0a

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

tests/UnifiedSpecTests/Operation.php

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -894,6 +894,15 @@ private function executeForTestRunner()
894894
assertInstanceOf(Session::class, $args['session']);
895895
assertNull($args['session']->getServer());
896896
break;
897+
case 'createEntities':
898+
assertArrayHasKey('entities', $args);
899+
assertIsArray($args['entities']);
900+
$this->context->createEntities($args['entities']);
901+
/* Ensure EventObserver and EventCollector for any new clients
902+
* are subscribed. This is a NOP for existing clients. */
903+
$this->context->startEventObservers();
904+
$this->context->startEventCollectors();
905+
break;
897906
case 'failPoint':
898907
assertArrayHasKey('client', $args);
899908
assertArrayHasKey('failPoint', $args);

tests/UnifiedSpecTests/Util.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ final class Util
5252
'assertSessionPinned' => ['session'],
5353
'assertSessionTransactionState' => ['session', 'state'],
5454
'assertSessionUnpinned' => ['session'],
55+
'createEntities' => ['entities'],
5556
'failPoint' => ['client', 'failPoint'],
5657
'targetedFailPoint' => ['session', 'failPoint'],
5758
'loop' => ['operations', 'storeErrorsAsEntity', 'storeFailuresAsEntity', 'storeSuccessesAsEntity', 'storeIterationsAsEntity'],

0 commit comments

Comments
 (0)