diff --git a/freppledb/forecast/commands.py b/freppledb/forecast/commands.py
index 36ac751dd5..b7e606bf22 100644
--- a/freppledb/forecast/commands.py
+++ b/freppledb/forecast/commands.py
@@ -1471,10 +1471,10 @@ def getWeight(cls, database=DEFAULT_DB_ALIAS, **kwargs):
             return -1
 
     @classmethod
-    def run(cls, database=DEFAULT_DB_ALIAS, **kwargs):
+    def run(cls, cluster=-1, database=DEFAULT_DB_ALIAS, **kwargs):
         import frepple
 
-        if "supply" in os.environ:
+        if cluster == -1:
             frepple.updatePlannedForecast()
         frepple.cache.flush()
         frepple.cache.write_immediately = True