From 1f9acb0e61d9c74e5b6e25225cfd3a7584f54777 Mon Sep 17 00:00:00 2001 From: fmendezh Date: Mon, 23 Sep 2024 14:28:56 +0200 Subject: [PATCH] https://github.com/gbif/pipelines/issues/1078 routing was using the wrong message --- .../tasks/occurrences/warehouse/DataWarehouseCallback.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/gbif/coordinator/tasks/src/main/java/org/gbif/pipelines/tasks/occurrences/warehouse/DataWarehouseCallback.java b/gbif/coordinator/tasks/src/main/java/org/gbif/pipelines/tasks/occurrences/warehouse/DataWarehouseCallback.java index 913234d9c..ecf04fac6 100644 --- a/gbif/coordinator/tasks/src/main/java/org/gbif/pipelines/tasks/occurrences/warehouse/DataWarehouseCallback.java +++ b/gbif/coordinator/tasks/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 */