diff --git a/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/beam/DistributionOutlierPipeline.java b/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/beam/DistributionOutlierPipeline.java
index 331c57975f..ad0460d2aa 100644
--- a/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/beam/DistributionOutlierPipeline.java
+++ b/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/beam/DistributionOutlierPipeline.java
@@ -38,7 +38,7 @@ public static void main(String[] args) throws Exception {
         PipelinesOptionsFactory.create(DistributionOutlierPipelineOptions.class, combinedArgs);
     MDC.put("datasetId", options.getDatasetId());
     MDC.put("attempt", options.getAttempt().toString());
-    MDC.put("step", "DISTRIBUTION");
+    MDC.put("step", "OUTLIER");
     PipelinesOptionsFactory.registerHdfs(options);
     run(options);
     System.exit(0);