diff --git a/go.mod b/go.mod index 93bd043dca0ff8f8aa35a4ef2df331a3af9b5e81..03b9cb7efe5098f6dd9a4651211477114eed511b 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module gitlab.schukai.com/oss/libraries/go/services/job-queues +module gitlab.schukai.com/oss/libraries/go/services/job-queues.git go 1.22 diff --git a/manager.go b/manager.go index 4a9e63f58ff3d34316ee5cab88c50972d62c0831..8b69760041e6b70f51f7961c2d50a8fab68b17d4 100644 --- a/manager.go +++ b/manager.go @@ -748,8 +748,8 @@ func (m *Manager) handleJobEvents() { if nextJob.GetScheduler() != nil { if nextJob.GetScheduler().IsAdHoc() { - eventBus := m.GetEventBus() - eventBus.Publish(JobFinished, nextJob) + //eventBus := m.GetEventBus() + //eventBus.Publish(JobFinished, nextJob) } } } diff --git a/worker.go b/worker.go index dd4333221eb2d19998f25215d8d456d58eea67b3..856910af24969a315d060148341d88048cecb28e 100644 --- a/worker.go +++ b/worker.go @@ -246,8 +246,8 @@ func (w *LocalWorker) run(jobChannel chan GenericJob, stopChan chan bool, cancel _ = w.manager.Sync(job) } - eventBus := w.manager.GetEventBus() - eventBus.Publish(JobDone, job.GetID()) + //eventBus := w.manager.GetEventBus() + //eventBus.Publish(JobDone, job.GetID()) }()