Fix broken workflow tests

automation/service/workflow_converter.go

@@ -709,7 +709,7 @@ func verifyStep(s *types.WorkflowStep, in, out types.WorkflowPathSet) types.Work
 					}
 				}
 
-				return errors.Internal("unexpected type %q for argument %q no step type %q", msgArg.Type, argName, s.Kind)
+				return errors.Internal("unexpected type %q for argument %q on step type %q", msgArg.Type, argName, s.Kind)
 			}
 		}
 
@@ -846,7 +846,7 @@ func verifyStep(s *types.WorkflowStep, in, out types.WorkflowPathSet) types.Work
 		checks = append(checks,
 			noRef,
 			// required "workflow" with handle or ID
-			requiredArg("workflow", expr.String{}, expr.ID{}),
+			requiredArg("workflow", expr.Handle{}, expr.ID{}),
 
 			// optional "scope" as expr.Vars
 			checkArg("scope", expr.Vars{}),

tests/workflows/0001_basics_test.go

@@ -35,6 +35,7 @@ func Test0001_basics_detect_datarace_issues(t *testing.T) {
 	for i := 0; i < 10; i++ {
 		wg.Add(1)
 		go t.Run(fmt.Sprintf("%d", i), func(t *testing.T) {
+			defer wg.Done()
 			var (
 				aux     = struct{ Foo int64 }{}
 				req     = require.New(t)
@@ -42,7 +43,6 @@ func Test0001_basics_detect_datarace_issues(t *testing.T) {
 			)
 			req.NoError(vars.Decode(&aux))
 			req.Equal(int64(42), aux.Foo)
-			wg.Done()
 		})
 	}
 

tests/workflows/main_test.go

@@ -149,9 +149,9 @@ func loadScenarioWithName(ctx context.Context, t *testing.T, scenario string) {
 	}
 
 	// Reload and register workflows
-	// if err = service.DefaultWorkflow.Load(ctx); err != nil {
-	// 	t.Fatalf("failed to reload workflows: %v", err)
-	// }
+	if err = service.DefaultWorkflow.Load(ctx); err != nil {
+		t.Fatalf("failed to reload workflows: %v", err)
+	}
 }
 
 func bypassRBAC(ctx context.Context) context.Context {