diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearCacheClusterCommand.java b/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearCacheClusterCommand.java
index 02a03263b..622e0d1d9 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearCacheClusterCommand.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/workers/ClearCacheClusterCommand.java
@@ -15,6 +15,6 @@ public class ClearCacheClusterCommand extends ConfiguredCommand<WhisperServerCon
     @Override
     protected void run(final Bootstrap<WhisperServerConfiguration> bootstrap, final Namespace namespace, final WhisperServerConfiguration config) {
         final FaultTolerantRedisCluster cacheCluster = new FaultTolerantRedisCluster("main_cache_cluster", config.getCacheClusterConfiguration().getUrls(), config.getCacheClusterConfiguration().getTimeout(), config.getCacheClusterConfiguration().getCircuitBreakerConfiguration());
-        cacheCluster.useWriteCluster(connection -> connection.sync().flushall());
+        cacheCluster.useWriteCluster(connection -> connection.sync().flushallAsync());
     }
 }