Skip to content

Commit f4727e3

Browse files
committed
[core] Adapt to new Bookkeeping lhcInfo parameter names
1 parent 098ea73 commit f4727e3

File tree

1 file changed

+5
-6
lines changed

1 file changed

+5
-6
lines changed

core/integration/bookkeeping/plugin.go

+5-6
Original file line numberDiff line numberDiff line change
@@ -1265,7 +1265,6 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
12651265

12661266
inEnv := bkpb.EnvironmentUpdateRequest{
12671267
Id: env.Id().String(),
1268-
ToredownAt: &toredownAt,
12691268
Status: &status,
12701269
StatusMessage: &statusMessage,
12711270
}
@@ -1444,11 +1443,11 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
14441443
parentRole.SetGlobalRuntimeVar("fill_info_fill_number", string(lhcInfo.FillNumber))
14451444
parentRole.SetGlobalRuntimeVar("fill_info_filling_scheme", lhcInfo.FillingSchemeName)
14461445
parentRole.SetGlobalRuntimeVar("fill_info_beam_type", lhcInfo.BeamType)
1447-
if lhcInfo.StableBeamStart != nil {
1448-
parentRole.SetGlobalRuntimeVar("fill_info_stable_beam_start_ms", strconv.FormatInt(*lhcInfo.StableBeamStart, 10))
1446+
if lhcInfo.StableBeamsStart != nil {
1447+
parentRole.SetGlobalRuntimeVar("fill_info_stable_beam_start_ms", strconv.FormatInt(*lhcInfo.StableBeamsStart, 10))
14491448
}
1450-
if lhcInfo.StableBeamEnd != nil {
1451-
parentRole.SetGlobalRuntimeVar("fill_info_stable_beam_end_ms", strconv.FormatInt(*lhcInfo.StableBeamEnd, 10))
1449+
if lhcInfo.StableBeamsEnd != nil {
1450+
parentRole.SetGlobalRuntimeVar("fill_info_stable_beam_end_ms", strconv.FormatInt(*lhcInfo.StableBeamsEnd, 10))
14521451
}
14531452
log.WithField("partition", envId).
14541453
WithField("level", infologger.IL_Devel).
@@ -1540,7 +1539,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
15401539
Error("bookkeeping plugin RetrieveFillInfo error")
15411540
call.VarStack["__call_error_reason"] = err.Error()
15421541
call.VarStack["__call_error"] = callFailedStr
1543-
} else if (lhcFill.StableBeamStart != nil && *lhcFill.StableBeamStart != 0) && (lhcFill.StableBeamEnd == nil || *lhcFill.StableBeamEnd == 0) {
1542+
} else if (lhcFill.StableBeamsStart != nil && *lhcFill.StableBeamsStart != 0) && (lhcFill.StableBeamsEnd == nil || *lhcFill.StableBeamsEnd == 0) {
15441543
// we enter here only if stable beams started and are not over (stable beams start exists && stable beams end does not exist)
15451544
log.WithField("partition", envId).
15461545
WithField("level", infologger.IL_Devel).

0 commit comments

Comments
 (0)