diff --git a/lib/defaultCommandHandler.js b/lib/defaultCommandHandler.js
index 3836525..5697d98 100644
--- a/lib/defaultCommandHandler.js
+++ b/lib/defaultCommandHandler.js
@@ -614,7 +614,7 @@ _.extend(DefaultCommandHandler.prototype, {
             var retryIn = randomBetween(0, self.options.retryOnConcurrencyTimeout); // could be overwritten in a custom commandHandler?
             debug('retry in ' + retryIn + 'ms');
             setTimeout(function() {
-              self.workflow(cmd, callback);
+              self.workflow(aggId, cmd, callback);
             }, retryIn);
             return;
           }