add description for jobtracker errors (#2840)

airbytehq · Apr 12, 2021 · bc11c57 · bc11c57
1 parent 5216ea7
commit bc11c57
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...er/persistence/src/main/java/io/airbyte/scheduler/persistence/job_tracker/JobTracker.java b/...er/persistence/src/main/java/io/airbyte/scheduler/persistence/job_tracker/JobTracker.java
@@ -114,7 +114,8 @@ public void trackDiscover(UUID jobId, UUID sourceDefinitionId, JobState jobState
   public void trackSync(Job job, JobState jobState) {
     Exceptions.swallow(() -> {
       final ConfigType configType = job.getConfigType();
-      Preconditions.checkArgument(configType == ConfigType.SYNC || configType == ConfigType.RESET_CONNECTION);
+      final boolean allowedJob = configType == ConfigType.SYNC || configType == ConfigType.RESET_CONNECTION;
+      Preconditions.checkArgument(allowedJob, "Job type " + configType + " is not allowed!");
       final long jobId = job.getId();
       final UUID connectionId = UUID.fromString(job.getScope());
       final UUID sourceDefinitionId = configRepository.getSourceDefinitionFromConnection(connectionId).getSourceDefinitionId();