(predicate string)
| 120 | } |
| 121 | |
| 122 | func undoSchemaUpdate(predicate string) { |
| 123 | maxRetries := 10 |
| 124 | loadErr := x.RetryUntilSuccess(maxRetries, 10*time.Millisecond, func() error { |
| 125 | return schema.Load(predicate) |
| 126 | }) |
| 127 | |
| 128 | if loadErr != nil { |
| 129 | glog.Fatalf("failed to load schema after %d retries: %v", maxRetries, loadErr) |
| 130 | } |
| 131 | } |
| 132 | |
| 133 | func runSchemaMutation(ctx context.Context, updates []*pb.SchemaUpdate, startTs uint64) error { |
| 134 | if len(updates) == 0 { |
no test coverage detected