diff --git a/api/runner/async_runner.go b/api/runner/async_runner.go index a7fb1c9b2..0e3e214d8 100644 --- a/api/runner/async_runner.go +++ b/api/runner/async_runner.go @@ -100,7 +100,7 @@ func RunAsyncRunner(tasksrv, port string) { for { task, err := getTask(u) if err != nil { - log.WithError(err) + log.WithError(err).Info("Cannot get task") time.Sleep(1 * time.Second) continue } diff --git a/main.go b/main.go index d8b8547e0..49a96be95 100644 --- a/main.go +++ b/main.go @@ -24,8 +24,8 @@ func init() { viper.SetDefault("mq", fmt.Sprintf("bolt://%s/data/worker_mq.db", cwd)) viper.SetDefault("db", fmt.Sprintf("bolt://%s/data/bolt.db?bucket=funcs", cwd)) viper.SetDefault("port", 8080) - viper.SetDefault("tasksrv", fmt.Sprintf("http://localhost:%d", viper.GetInt("port"))) - viper.SetDefault("NASYNC", 1) + viper.SetDefault("tasks_url", fmt.Sprintf("http://localhost:%d", viper.GetInt("port"))) + viper.SetDefault("nasync", 1) viper.SetConfigName("config") viper.AddConfigPath(".") viper.AutomaticEnv() // picks up env vars automatically @@ -55,9 +55,11 @@ func main() { log.WithError(err).Fatalln("Failed to create a runner") } - tasksrv, port := viper.GetString("PORT"), viper.GetString("TASKSVR") - for nasync, i := viper.GetInt("NASYNC"), 0; i < nasync; i++ { - go runner.RunAsyncRunner(tasksrv, port) + tasksURL, port, nasync := viper.GetString("tasks_url"), viper.GetString("port"), viper.GetInt("nasync") + log.Info("async workers:", nasync) + log.Fatal(tasksURL) + for i := 0; i < nasync; i++ { + go runner.RunAsyncRunner(tasksURL, port) } srv := server.New(ds, mqType, rnr)