Skip to content

Commit 24e802e

Browse files
committed
Remove obsolete err check
The need for the check was removed in 4fb6ba0
1 parent faa6de6 commit 24e802e

File tree

1 file changed

+7
-11
lines changed

1 file changed

+7
-11
lines changed

core/environment/environment.go

Lines changed: 7 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -240,17 +240,13 @@ func newEnvironment(userVars map[string]string, newId uid.ID) (env *Environment,
240240
}
241241
env.GlobalVars.Set("__fmq_cleanup_count", strconv.Itoa(cleanupCount)) // number of times the START transition has run for this env
242242

243-
if err == nil {
244-
lhcPeriod, ok := env.BaseConfigStack["lhc_period"]
245-
if ok {
246-
env.workflow.GetVars().Set("lhc_period", lhcPeriod)
247-
}
248-
nHbfPerTf, ok := env.BaseConfigStack["pdp_n_hbf_per_tf"]
249-
if ok {
250-
env.workflow.GetVars().Set("pdp_n_hbf_per_tf", nHbfPerTf)
251-
}
252-
} else {
253-
log.Error("cannot access AliECS workflow configuration defaults")
243+
lhcPeriod, ok := env.BaseConfigStack["lhc_period"]
244+
if ok {
245+
env.workflow.GetVars().Set("lhc_period", lhcPeriod)
246+
}
247+
nHbfPerTf, ok := env.BaseConfigStack["pdp_n_hbf_per_tf"]
248+
if ok {
249+
env.workflow.GetVars().Set("pdp_n_hbf_per_tf", nHbfPerTf)
254250
}
255251
} else if e.Event == "STOP_ACTIVITY" {
256252
endTime, ok := env.workflow.GetUserVars().Get("run_end_time_ms")

0 commit comments

Comments
 (0)