diff --git a/src/main/java/com/conveyal/r5/analyst/cluster/AnalysisWorker.java b/src/main/java/com/conveyal/r5/analyst/cluster/AnalysisWorker.java index 2add61702..46bfed946 100644 --- a/src/main/java/com/conveyal/r5/analyst/cluster/AnalysisWorker.java +++ b/src/main/java/com/conveyal/r5/analyst/cluster/AnalysisWorker.java @@ -41,6 +41,7 @@ import java.util.Arrays; import java.util.List; import java.util.Random; +import java.util.Set; import java.util.UUID; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; @@ -407,6 +408,10 @@ protected void handleOneRegionalTask (RegionalTask task) throws Throwable { LOG.debug("Handling regional task {}", task.toString()); + // Force dual access results for grid (remove once broker has been relaunched to support custom flags) + LOG.info("Forcing dual access results"); + task.flags = Set.of("gridDualAccess"); + if (task.injectFault != null) { task.injectFault.considerShutdownOrException(task.taskId); if (task.injectFault.shouldDropTaskBeforeCompute(task.taskId)) {