From 2bb74106a03738c80e384ee267ef57bc40ab8c92 Mon Sep 17 00:00:00 2001
From: Volker Schukai <volker.schukai@schukai.com>
Date: Sat, 28 Sep 2024 22:40:52 +0200
Subject: [PATCH] fix: move flake.nix
---
go.mod | 2 +-
manager.go | 4 ++--
worker.go | 4 ++--
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/go.mod b/go.mod
index 93bd043..03b9cb7 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 4a9e63f..8b69760 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 dd43332..856910a 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())
}()
--
GitLab