diff --git a/server/workflow/trigger/fileaction.go b/server/workflow/trigger/fileaction.go
index 3d98fb4b..a4cf720d 100644
--- a/server/workflow/trigger/fileaction.go
+++ b/server/workflow/trigger/fileaction.go
@@ -86,7 +86,7 @@ func processFileAction(ctx *App, params map[string]string) {
 	if ctx.Context.Value("AUDIT") == false {
 		return
 	}
-	if err := triggerEvents(fileaction_event, fileaction_name, fileactionCallback(params)); err != nil {
+	if err := TriggerEvents(fileaction_event, fileaction_name, fileactionCallback(params)); err != nil {
 		Log.Error("[workflow] trigger=event step=triggerEvents err=%s", err.Error())
 	}
 }
diff --git a/server/workflow/trigger/filewatch.go b/server/workflow/trigger/filewatch.go
index 80fb40ba..eefcb35d 100644
--- a/server/workflow/trigger/filewatch.go
+++ b/server/workflow/trigger/filewatch.go
@@ -47,7 +47,7 @@ func (this *WatchTrigger) Manifest() WorkflowSpecs {
 func (this *WatchTrigger) Init() (chan ITriggerEvent, error) {
 	go func() {
 		for {
-			if err := triggerEvents(filewatch_event, filewatch_name, filewatchCallback); err != nil {
+			if err := TriggerEvents(filewatch_event, filewatch_name, filewatchCallback); err != nil {
 				Log.Error("[workflow] trigger=watch step=triggerEvents err=%s", err.Error())
 			}
 			time.Sleep(10 * time.Second)
diff --git a/server/workflow/trigger/index.go b/server/workflow/trigger/index.go
index 0416dbc0..d17fcebf 100644
--- a/server/workflow/trigger/index.go
+++ b/server/workflow/trigger/index.go
@@ -21,7 +21,7 @@ func (this *TriggerEvent) WorkflowID() string {
 	return this.ID
 }
 
-func triggerEvents(event chan ITriggerEvent, triggerID string, callback func(params map[string]string) (map[string]string, bool)) error {
+func TriggerEvents(event chan ITriggerEvent, triggerID string, callback func(params map[string]string) (map[string]string, bool)) error {
 	workflows, err := FindWorkflows(triggerID)
 	if err != nil {
 		return err
diff --git a/server/workflow/trigger/schedule.go b/server/workflow/trigger/schedule.go
index ae20a873..aa8c4ed0 100644
--- a/server/workflow/trigger/schedule.go
+++ b/server/workflow/trigger/schedule.go
@@ -40,7 +40,7 @@ func (this *ScheduleTrigger) Manifest() WorkflowSpecs {
 func (this *ScheduleTrigger) Init() (chan ITriggerEvent, error) {
 	go func() {
 		for {
-			if err := triggerEvents(cron_event, cron_name, scheduleCallback); err != nil {
+			if err := TriggerEvents(cron_event, cron_name, scheduleCallback); err != nil {
 				Log.Error("[workflow] trigger=schedule step=triggerEvents err=%s", err.Error())
 			}
 			time.Sleep(60 * time.Second)
diff --git a/server/workflow/trigger/webhook.go b/server/workflow/trigger/webhook.go
index e5f78e74..4c9667ed 100644
--- a/server/workflow/trigger/webhook.go
+++ b/server/workflow/trigger/webhook.go
@@ -18,7 +18,7 @@ func init() {
 	Hooks.Register.WorkflowTrigger(&WebhookTrigger{})
 	Hooks.Register.HttpEndpoint(func(r *mux.Router, app *App) error {
 		r.HandleFunc(WithBase("/api/workflow/webhook"), func(w http.ResponseWriter, r *http.Request) {
-			if err := triggerEvents(webhook_event, webhook_name, webhookCallback(r)); err != nil {
+			if err := TriggerEvents(webhook_event, webhook_name, webhookCallback(r)); err != nil {
 				SendErrorResult(w, err)
 				return
 			}