func FilterWorkflowTaskInputData()

in internal/filter/data_filter.go [25:35]

• 11 lines of code
• 5 McCabe index (conditional complexity)

func FilterWorkflowTaskInputData(task *model.WorkflowTaskInstance) {
	if task == nil || len(task.Input) == 0 || len(task.Task.TaskInputFilter) == 0 {
		return
	}
	inputAfterFilter, err := filterJsonData(task.Task.TaskInputFilter, task.Input)
	if err != nil {
		log.Errorf("fail to filter task input data taskId=%s, err=%v", task.TaskID, err)
		return
	}
	task.Input = inputAfterFilter
}