Skip to content

Commit

Permalink
Merge pull request #456 from ml054/v5.4
Browse files Browse the repository at this point in the history
tuning flacky test
  • Loading branch information
ml054 committed Aug 27, 2024
2 parents 69cd00a + cb572f3 commit 5050de8
Showing 1 changed file with 8 additions and 5 deletions.
13 changes: 8 additions & 5 deletions test/Ported/Server/Replication/PullReplicationTest.ts
Original file line number Diff line number Diff line change
Expand Up @@ -221,7 +221,7 @@ import { delay } from "../../../../src/Utility/PromiseUtil";
const definitionName1 = "pull-replication" + hub.database;
const definitionName2 = "pull-replication" + hub2.database;

const timeout = 3_000;
const timeout = 15_000;

await hub.maintenance.forDatabase(hub.database).send(new PutPullReplicationAsHubOperation(definitionName1));
await hub2.maintenance.forDatabase(hub2.database).send(new PutPullReplicationAsHubOperation(definitionName2));
Expand All @@ -240,7 +240,8 @@ import { delay } from "../../../../src/Utility/PromiseUtil";
connectionStringName: "ConnectionString2-" + sink.database,
hubName: definitionName2,
taskId: pullTasks[0].taskId,
mode: "HubToSink"
mode: "HubToSink",
url: sink.urls[0]
};

await ReplicationTestContext.addWatcherToReplicationTopology(sink, pull, ...hub2.urls);
Expand Down Expand Up @@ -348,7 +349,7 @@ import { delay } from "../../../../src/Utility/PromiseUtil";
hub = await testContext.getDocumentStore();

const definitionName = "pull-replication" + hub.database;
const timeout = 10_000;
const timeout = 15_000;

await hub.maintenance.forDatabase(hub.database)
.send(new PutPullReplicationAsHubOperation(definitionName));
Expand All @@ -369,7 +370,8 @@ import { delay } from "../../../../src/Utility/PromiseUtil";
hubName: definitionName,
disabled: true,
taskId: pullTasks[0].taskId,
mode: "HubToSink"
mode: "HubToSink",
url: sink.urls[0],
};

await ReplicationTestContext.addWatcherToReplicationTopology(sink, pull, ...hub.urls);
Expand Down Expand Up @@ -515,7 +517,8 @@ async function setupPullReplication(remoteName: string, sink: IDocumentStore, ..
database: store.database,
connectionStringName: "ConnectionString-" + store.database,
hubName: remoteName,
mode: "HubToSink"
mode: "HubToSink",
url: sink.urls[0],
};

resList.push(await ReplicationTestContext.addWatcherToReplicationTopology(sink, pull, ...store.urls));
Expand Down

0 comments on commit 5050de8

Please sign in to comment.