46
// updateSchema executes the updateSchemaTask
47
// using the given command line args as input
48
>
func updateSchema(cli *cli.Context, logger log.Logger) error {
handler.go
49
>
config, err := newCQLClientConfig(cli)
50
>
if err != nil {
51
logger.Error("Unable to read config.", tag.Error(schema.NewConfigError(err.Error())))
52
return err
53
}
54
>
client, err := newCQLClient(config, logger)
handler.go
55
>
if err != nil {
56
logger.Error("Unable to establish CQL session.", tag.Error(err))
57
return err
58
}
60
>
if err := schema.Update(cli, client, logger); err != nil {
61
logger.Error("Unable to update CQL schema.", tag.Error(err))
62
return err
63
}
65
}
66