Function waitForJobs

src/go/cmd/godplugin/main.go:362–373

(ctx context.Context, mgr *jobmgr.Manager, moduleName string)

}

func waitForJobs(ctx context.Context, mgr *jobmgr.Manager, moduleName string) error {
	for {
		if len(mgr.GetJobNames(moduleName)) > 0 {
			return nil
		}
		select {
		case <-ctx.Done():
			return fmt.Errorf("no jobs started for module '%s'", moduleName)
		case <-time.After(100 * time.Millisecond):
		}
	}
}

func writeFunctionError(status int, format string, args ...any) {
	resp := map[string]any{