diff --git a/machinery/data/config/config.json b/machinery/data/config/config.json index f39b878..6b74832 100644 --- a/machinery/data/config/config.json +++ b/machinery/data/config/config.json @@ -98,6 +98,7 @@ "region": "eu-west-1" }, "kstorage": {}, + "kstorage_secondary": {}, "dropbox": {}, "mqtturi": "tcp://mqtt.kerberos.io:1883", "mqtt_username": "", diff --git a/machinery/src/config/main.go b/machinery/src/config/main.go index 5a68876..c29c8d7 100644 --- a/machinery/src/config/main.go +++ b/machinery/src/config/main.go @@ -183,15 +183,19 @@ func OpenConfig(configDirectory string, configuration *models.Configuration) { } jsonFile.Close() } - } - return } // This function will override the configuration with environment variables. func OverrideWithEnvironmentVariables(configuration *models.Configuration) { environmentVariables := os.Environ() + + // Initialize the configuration for some new fields. + if configuration.Config.KStorageSecondary == nil { + configuration.Config.KStorageSecondary = &models.KStorage{} + } + for _, env := range environmentVariables { if strings.Contains(env, "AGENT_") { key := strings.Split(env, "=")[0]