diff --git a/backend/internal/grpcsrv/commander/commander.go b/backend/internal/grpcsrv/commander/commander.go index ba0cec0..2bc35a9 100644 --- a/backend/internal/grpcsrv/commander/commander.go +++ b/backend/internal/grpcsrv/commander/commander.go @@ -81,6 +81,7 @@ func (self *Agent) AddJob(job models.JobForInsert) (int64, error) { if err != nil { return 0, err } + self.jobs[jid] = newJob() self.in <- &proto.Command{ Id: jid, Command: job.Command, @@ -155,7 +156,6 @@ func (self *Agent) recv() error { func (self *Agent) send() error { for job := range self.in { - self.jobs[job.Id] = newJob() if err := self.bidi.Send(job); err != nil { return err }