Plemya-x/ALR-updater
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Исправление работы планировщика

Browse Source
This commit is contained in:
Евгений Храмов
2025-10-05 00:36:21 +03:00
parent cbca05ef41
commit bb91f35e58
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
internal/builtins/run_every.go
View File

@@ -180,8 +180,9 @@ func runScheduled(thread *starlark.Thread, fn *starlark.Function, duration strin
// Запускаем функцию немедленно при первой регистрации // Запускаем функцию немедленно при первой регистрации
go func() { go func() {
newThread := &starlark.Thread{Name: thread.Name}
log.Info("Running plugin function immediately on startup").Str("plugin", thread.Name).Str("function", fn.Name()).Send() log.Info("Running plugin function immediately on startup").Str("plugin", thread.Name).Str("function", fn.Name()).Send()
_, err := starlark.Call(thread, fn, nil, nil) _, err := starlark.Call(newThread, fn, nil, nil)
if err != nil { if err != nil {
log.Warn("Error while executing initial plugin function").Str("plugin", thread.Name).Str("function", fn.Name()).Err(err).Send() log.Warn("Error while executing initial plugin function").Str("plugin", thread.Name).Str("function", fn.Name()).Err(err).Send()
} }
@@ -189,10 +190,11 @@ func runScheduled(thread *starlark.Thread, fn *starlark.Function, duration strin
go func() { go func() {
for range t.C { for range t.C {
log.Debug("Calling scheduled function").Str("name", fn.Name()).Stringer("pos", fn.Position()).Send() newThread := &starlark.Thread{Name: thread.Name}
_, err := starlark.Call(thread, fn, nil, nil) log.Info("Calling scheduled function").Str("plugin", thread.Name).Str("function", fn.Name()).Send()
_, err := starlark.Call(newThread, fn, nil, nil)
if err != nil { if err != nil {
log.Warn("Error while executing scheduled function").Str("name", fn.Name()).Stringer("pos", fn.Position()).Err(err).Send() log.Warn("Error while executing scheduled function").Str("plugin", thread.Name).Str("function", fn.Name()).Err(err).Send()
} }
} }
}() }()