https://github.com/gbif/pipelines/issues/1078

routing was using the wrong message
gbif · Sep 23, 2024 · 1f9acb0 · 1f9acb0
1 parent 92b2970
commit 1f9acb0
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...s/src/main/java/org/gbif/pipelines/tasks/occurrences/warehouse/DataWarehouseCallback.java b/...s/src/main/java/org/gbif/pipelines/tasks/occurrences/warehouse/DataWarehouseCallback.java
@@ -8,7 +8,6 @@
 import org.gbif.common.messaging.api.MessagePublisher;
 import org.gbif.common.messaging.api.messages.PipelinesHdfsViewMessage;
 import org.gbif.common.messaging.api.messages.PipelinesInterpretationMessage;
-import org.gbif.common.messaging.api.messages.PipelinesInterpretedMessage;
 import org.gbif.pipelines.common.PipelinesVariables;
 import org.gbif.pipelines.common.airflow.AppName;
 import org.gbif.pipelines.common.process.AirflowSparkLauncher;
@@ -51,7 +50,7 @@ public void handleMessage(PipelinesHdfsViewMessage message) {
 
   @Override
   public String getRouting() {
-    return new PipelinesInterpretedMessage().setRunner(config.processRunner).getRoutingKey();
+    return new PipelinesHdfsViewMessage().setRunner(config.processRunner).getRoutingKey();
   }
 
   /** Main message processing logic, creates a terminal java process, which runs */