From 8c3b570ecc525f3b1a4e1fd7fe21d1cf42686d37 Mon Sep 17 00:00:00 2001 From: Ingo Oppermann Date: Mon, 15 May 2023 21:31:58 +0200 Subject: [PATCH] Fix log transfer --- restream/restream.go | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/restream/restream.go b/restream/restream.go index eb014297..7b252d2a 100644 --- a/restream/restream.go +++ b/restream/restream.go @@ -875,12 +875,6 @@ func (r *restream) UpdateProcess(id string, config *app.Config) error { return ErrUnknownProcess } - // This would require a major version jump - //t.process.CreatedAt = task.process.CreatedAt - t.process.UpdatedAt = time.Now().Unix() - task.parser.TransferReportHistory(t.parser) - t.process.Order = task.process.Order - if id != t.id { _, ok := r.tasks[t.id] if ok { @@ -888,6 +882,8 @@ func (r *restream) UpdateProcess(id string, config *app.Config) error { } } + t.process.Order = task.process.Order + if err := r.stopProcess(id); err != nil { return err } @@ -896,6 +892,11 @@ func (r *restream) UpdateProcess(id string, config *app.Config) error { return err } + // This would require a major version jump + //t.process.CreatedAt = task.process.CreatedAt + t.process.UpdatedAt = time.Now().Unix() + task.parser.TransferReportHistory(t.parser) + r.tasks[t.id] = t // set filesystem cleanup rules