diff --git a/pkg/microservice/aslan/core/workflow/service/workflow/workflow_task_v4.go b/pkg/microservice/aslan/core/workflow/service/workflow/workflow_task_v4.go index aaf54971aa..8d35eb1847 100644 --- a/pkg/microservice/aslan/core/workflow/service/workflow/workflow_task_v4.go +++ b/pkg/microservice/aslan/core/workflow/service/workflow/workflow_task_v4.go @@ -1111,11 +1111,11 @@ func RevertWorkflowTaskV4Job(workflowName, jobName string, taskID int64, input i return fmt.Errorf("failed to decode nacos job spec, error: %s", err) } inputSpec := make([]*commonmodels.NacosData, 0) - if err := commonmodels.IToi(input, inputSpec); err != nil { log.Errorf("failed to decode nacos revert input spec, error: %s", err) return fmt.Errorf("failed to decode nacos revert input spec, error: %s", err) } + log.Infof("input spec length is: %d", len(inputSpec)) err = revertNacosJob(jobTaskSpec, inputSpec) if err != nil {