wip

Author: yanavasileva

data-migrator/core/src/main/java/io/camunda/migration/data/impl/history/migrator/JobMigrator.java

@@ -30,7 +30,6 @@
 import java.util.function.Consumer;
 import java.util.function.Function;
 import org.camunda.bpm.engine.history.HistoricJobLog;
-import org.camunda.bpm.engine.impl.jobexecutor.MessageJobDeclaration;
 import org.springframework.stereotype.Service;
 
 /**
@@ -86,10 +85,10 @@ public Long migrateTransactionally(final HistoricJobLog c7JobLog) {
     final String c7JobId = c7JobLog.getJobId();
     if (shouldMigrate(c7JobId, HISTORY_JOB)) {
       String jobDefinitionConfiguration = c7JobLog.getJobDefinitionConfiguration();
+      logMigratingJob(c7JobId);
       if (ASYNC_BEFORE.equals(jobDefinitionConfiguration) && ASYNC_AFTER.equals(jobDefinitionConfiguration)) {
         throw new EntitySkippedException(c7JobLog, SKIP_REASON_UNSUPPORTED_JOBS); //TODO test case for non-async jobs
       }
-      logMigratingJob(c7JobId);
 
       final var jobKey = getNextKey();
       final var builder = new JobDbModel.Builder().jobKey(jobKey);

data-migrator/qa/integration-tests/src/test/java/io/camunda/migration/data/qa/history/entity/HistoryJobTest.java

@@ -141,7 +141,5 @@ public void shouldDeduplicateJobsByJobId() {
     List<JobEntity> c8Jobs = searchJobs(processInstances.getFirst().processInstanceKey());
     assertThat(c8Jobs).as("Exactly one C8 job per C7 job despite multiple log entries").hasSize(1);
 
-    // and: the job is tracked in the migration table by C7 job ID
-    assertThat(dbClient.checkExistsByC7IdAndType(job.getId(), HISTORY_JOB)).isTrue();
   }
 }