Fix log transfer
This commit is contained in:
parent
6046bc34c9
commit
8c3b570ecc
1 changed files with 7 additions and 6 deletions
|
|
@ -875,12 +875,6 @@ func (r *restream) UpdateProcess(id string, config *app.Config) error {
|
||||||
return ErrUnknownProcess
|
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 {
|
if id != t.id {
|
||||||
_, ok := r.tasks[t.id]
|
_, ok := r.tasks[t.id]
|
||||||
if ok {
|
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 {
|
if err := r.stopProcess(id); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
@ -896,6 +892,11 @@ func (r *restream) UpdateProcess(id string, config *app.Config) error {
|
||||||
return err
|
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
|
r.tasks[t.id] = t
|
||||||
|
|
||||||
// set filesystem cleanup rules
|
// set filesystem cleanup rules
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue