+ go func() {
+ server := server.CreateServer(configuration.InfoJobCallbackPort, server.CreateInfoJobHandler)
+ log.Warn(server.ListenAndServe())
+ wg.Done()
+ }()
+
+ go func() {
+ jobs.RunJobs(fmt.Sprintf("%v:%v", configuration.MRHost, configuration.MRPort))
+ wg.Done()
+ }()
+
+ // wait until WaitGroup is done
+ wg.Wait()