diff --git a/packages/test/test-end-to-end-tests/src/test/rootDatastores.spec.ts b/packages/test/test-end-to-end-tests/src/test/rootDatastores.spec.ts index fd949e81b098..a90632e7c929 100644 --- a/packages/test/test-end-to-end-tests/src/test/rootDatastores.spec.ts +++ b/packages/test/test-end-to-end-tests/src/test/rootDatastores.spec.ts @@ -18,7 +18,7 @@ import { ITestObjectProvider, getContainerEntryPointBackCompat, summarizeNow, - waitForContainerConnection, + timeoutAwait, } from "@fluidframework/test-utils/internal"; import { TestPersistedCache } from "../testPersistedCache.js"; @@ -44,12 +44,12 @@ describeCompat("Named root data stores", "FullCompat", (getTestObjectProvider) = let provider: ITestObjectProvider; const testPersistedCache = new TestPersistedCache(); beforeEach("getTestObjectProvider", async () => { - provider = getTestObjectProvider({ persistedCache: testPersistedCache }); + provider = getTestObjectProvider({ + persistedCache: testPersistedCache, + syncSummarizer: true, + }); container1 = await provider.makeTestContainer(testContainerConfig); dataObject1 = await getContainerEntryPointBackCompat(container1); - await waitForContainerConnection(container1); - - await provider.ensureSynchronized(); container2 = await provider.loadTestContainer(testContainerConfig); dataObject2 = await getContainerEntryPointBackCompat(container2); @@ -270,12 +270,11 @@ describeCompat("Named root data stores", "FullCompat", (getTestObjectProvider) = assert.equal(aliasResult1, "Success"); assert.equal(aliasResult2, "Conflict"); - await provider.ensureSynchronized(); const container3 = await provider.loadTestContainer(testContainerConfig); const dataObject3 = await getContainerEntryPointBackCompat(container3); await provider.ensureSynchronized(); - assert.ok(await getAliasedDataStoreEntryPoint(dataObject3, alias)); + assert.ok(await timeoutAwait(getAliasedDataStoreEntryPoint(dataObject3, alias))); }); it("getAliasedDataStoreEntryPoint only returns aliased data stores", async function () { @@ -334,11 +333,10 @@ describeCompat("Named root data stores", "FullCompat", (getTestObjectProvider) = assert.equal(aliasResult1, "Success"); assert.equal(aliasResult2, "Conflict"); - await provider.ensureSynchronized(); - const { summarizer } = await createSummarizer(provider, container1, { fluidDataObjectType: DataObjectFactoryType.Test, }); + await provider.ensureSynchronized(); const { summaryVersion } = await summarizeNow(summarizer); // For the ODSP driver, we need to clear the cache to ensure we get the latest snapshot @@ -355,7 +353,7 @@ describeCompat("Named root data stores", "FullCompat", (getTestObjectProvider) = const aliasResult3 = await ds3.trySetAlias(alias); assert.equal(aliasResult3, "Conflict"); - assert.ok(await getAliasedDataStoreEntryPoint(dataObject3, alias)); + assert.ok(await timeoutAwait(getAliasedDataStoreEntryPoint(dataObject3, alias))); }, ); });