From 18376aa64b703ebbb31b6a2c089ab1561edcabf9 Mon Sep 17 00:00:00 2001 From: Jan Eitzinger Date: Fri, 14 Mar 2025 09:59:05 +0100 Subject: [PATCH] Backup commit --- internal/api/nats.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/api/nats.go b/internal/api/nats.go index b5a4ac3..43d44e8 100644 --- a/internal/api/nats.go +++ b/internal/api/nats.go @@ -9,6 +9,7 @@ import ( "github.com/ClusterCockpit/cc-backend/internal/config" "github.com/ClusterCockpit/cc-backend/pkg/log" + "github.com/ClusterCockpit/cc-backend/pkg/schema" lp "github.com/ClusterCockpit/cc-lib/ccMessage" "github.com/ClusterCockpit/cc-lib/sinks" ) @@ -51,5 +52,6 @@ func Shutdown() { } } -func forwardJob() { +func forwardJob(job schema.BaseJob) { + payload := lp.NewEvent("start_job", nil , meta map[string]string, event string, tm time.Time) }