err = flow.runSQLTx(ctx, func(tx *database.SQLStore) error {
        ns, err = tx.DataStore().Namespaces().GetByName(ctx, in.GetNamespace())
        if err != nil {
            return err
        }