in job/main.go [77:98]
func main() {
config, err := configFromEnv()
if err != nil {
log.Fatal(err)
}
log.Printf("Starting Task #%s, Attempt #%s ...", config.taskNum, config.attemptNum)
// Simulate work
if config.sleepMs > 0 {
time.Sleep(time.Duration(config.sleepMs) * time.Millisecond)
}
// Simulate errors
if config.failRate > 0 {
if failure := randomFailure(config); failure != nil {
log.Fatalf("%v", failure)
}
}
log.Printf("Completed Task #%s, Attempt #%s", config.taskNum, config.attemptNum)
}