Update unit test

apache · Sep 20, 2023 · 8a6daa0 · 8a6daa0
1 parent 3bcacc2
commit 8a6daa0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ta/pipeline/scenario/migration/check/consistency/MigrationDataConsistencyCheckerTest.java b/...ta/pipeline/scenario/migration/check/consistency/MigrationDataConsistencyCheckerTest.java
@@ -64,15 +64,15 @@ void assertCountAndDataCheck() throws SQLException {
         governanceRepositoryAPI.persist(String.format("/pipeline/jobs/%s/config", jobConfig.getJobId()), YamlEngine.marshal(jobConfigurationPOJO));
         governanceRepositoryAPI.persistJobItemProgress(jobConfig.getJobId(), 0, "");
         Map<String, TableDataConsistencyCheckResult> actual = new MigrationDataConsistencyChecker(jobConfig, new MigrationProcessContext(jobConfig.getJobId(), null),
-                createConsistencyCheckJobItemProgressContext()).check("FIXTURE", null);
+                createConsistencyCheckJobItemProgressContext(jobConfig.getJobId())).check("FIXTURE", null);
         String checkKey = "t_order";
         assertTrue(actual.get(checkKey).getCountCheckResult().isMatched());
         assertThat(actual.get(checkKey).getCountCheckResult().getSourceRecordsCount(), is(actual.get(checkKey).getCountCheckResult().getTargetRecordsCount()));
         assertTrue(actual.get(checkKey).getContentCheckResult().isMatched());
     }
 
-    private ConsistencyCheckJobItemProgressContext createConsistencyCheckJobItemProgressContext() {
-        return new ConsistencyCheckJobItemProgressContext("", 0, "H2");
+    private ConsistencyCheckJobItemProgressContext createConsistencyCheckJobItemProgressContext(final String jobId) {
+        return new ConsistencyCheckJobItemProgressContext(jobId, 0, "H2");
     }
 
     private MigrationJobConfiguration createJobConfiguration() throws SQLException {