diff --git a/go.mod b/go.mod
index 60fa5331a..0cf9d76ab 100644
--- a/go.mod
+++ b/go.mod
@@ -79,4 +79,4 @@ go 1.17
 
 replace github.com/nyaruka/gocommon => github.com/Ilhasoft/gocommon v1.16.2-weni
 
-replace github.com/nyaruka/goflow => github.com/weni-ai/goflow v1.4.0
+replace github.com/nyaruka/goflow => github.com/weni-ai/goflow v1.4.1-a1-dev
diff --git a/go.sum b/go.sum
index 59e1d273f..df524e3a6 100644
--- a/go.sum
+++ b/go.sum
@@ -329,8 +329,8 @@ github.com/tj/assert v0.0.0-20171129193455-018094318fb0/go.mod h1:mZ9/Rh9oLWpLLD
 github.com/tj/go-elastic v0.0.0-20171221160941-36157cbbebc2/go.mod h1:WjeM0Oo1eNAjXGDx2yma7uG2XoyRZTq1uv3M/o7imD0=
 github.com/tj/go-kinesis v0.0.0-20171128231115-08b17f58cb1b/go.mod h1:/yhzCV0xPfx6jb1bBgRFjl5lytqVqZXEaeqWP8lTEao=
 github.com/tj/go-spin v1.1.0/go.mod h1:Mg1mzmePZm4dva8Qz60H2lHwmJ2loum4VIrLgVnKwh4=
-github.com/weni-ai/goflow v1.4.0 h1:tH/H7/WeS21nvH1jXntQX6y+quCHVi6epByoV9hZXH0=
-github.com/weni-ai/goflow v1.4.0/go.mod h1:o0xaVWP9qNcauBSlcNLa79Fm2oCPV+BDpheFRa/D40c=
+github.com/weni-ai/goflow v1.4.1-a1-dev h1:fIqO2yhLNWgR6SpgVNqE4pY9w1rhKddj0ZG/0WjYAs8=
+github.com/weni-ai/goflow v1.4.1-a1-dev/go.mod h1:o0xaVWP9qNcauBSlcNLa79Fm2oCPV+BDpheFRa/D40c=
 github.com/yuin/goldmark v1.1.25/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.1.32/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
diff --git a/mailroom.go b/mailroom.go
index 40938c3c1..2f4d0e779 100644
--- a/mailroom.go
+++ b/mailroom.go
@@ -8,8 +8,8 @@ import (
 	"time"
 
 	"github.com/nyaruka/gocommon/storage"
+	"github.com/nyaruka/goflow/flows"
 	"github.com/nyaruka/goflow/flows/routers"
-	"github.com/nyaruka/goflow/services/webhooks"
 	"github.com/nyaruka/mailroom/core/queue"
 	"github.com/nyaruka/mailroom/runtime"
 	"github.com/nyaruka/mailroom/web"
@@ -77,7 +77,7 @@ func NewMailroom(config *runtime.Config) *Mailroom {
 	routers.SetZeroshotAPIURL(mr.rt.Config.ZeroshotAPIUrl)
 
 	// set whatsapp system user token to be used in goflow
-	webhooks.SetWhatsAppSystemUserToken(mr.rt.Config.WhatsappSystemUserToken)
+	flows.SetWhatsAppSystemUserToken(mr.rt.Config.WhatsappSystemUserToken)
 
 	return mr
 }