From 9f5aef7add2c68b095ecd4b1a1d6f0820f7fb459 Mon Sep 17 00:00:00 2001
From: Yash Mehrotra <yashmehrotra95@gmail.com>
Date: Tue, 30 Jan 2024 10:49:09 +0530
Subject: [PATCH] fix: only set job meta if unset

---
 context/context.go |  2 +-
 job/job.go         | 19 +++++++++++--------
 2 files changed, 12 insertions(+), 9 deletions(-)

diff --git a/context/context.go b/context/context.go
index b322d45c..5c8da42f 100644
--- a/context/context.go
+++ b/context/context.go
@@ -242,7 +242,7 @@ func (k Context) StartSpan(name string) (Context, trace.Span) {
 func getObjectMeta(ctx commons.Context) metav1.ObjectMeta {
 	o := ctx.Value("object")
 	if o == nil {
-		return metav1.ObjectMeta{Annotations: map[string]string{}, Labels: map[string]string{}}
+		return metav1.ObjectMeta{Annotations: make(map[string]string), Labels: make(map[string]string)}
 	}
 	return o.(metav1.ObjectMeta)
 }
diff --git a/job/job.go b/job/job.go
index 4817bba3..1387e2ef 100644
--- a/job/job.go
+++ b/job/job.go
@@ -13,7 +13,6 @@ import (
 	"github.com/samber/lo"
 	"go.opentelemetry.io/otel/codes"
 	"go.opentelemetry.io/otel/trace"
-	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
 const (
@@ -324,13 +323,17 @@ func (j *Job) init() {
 		j.Context = j.Context.WithoutName().WithName(j.Name)
 	}
 
-	j.Context = j.Context.WithObject(v1.ObjectMeta{
-		Name: j.Name,
-		Annotations: map[string]string{
-			"debug": lo.Ternary(j.Debug, "true", "false"),
-			"trace": lo.Ternary(j.Trace, "true", "false"),
-		},
-	})
+	obj := j.Context.GetObjectMeta()
+	if obj.Name == "" {
+		obj.Name = j.Name
+	}
+	if obj.Annotations == nil {
+		obj.Annotations = make(map[string]string)
+	}
+	obj.Annotations["debug"] = lo.Ternary(j.Debug, "true", "false")
+	obj.Annotations["trace"] = lo.Ternary(j.Trace, "true", "false")
+
+	j.Context = j.Context.WithObject(obj)
 
 	if dbLevel, ok := getProperty(j, properties, "db-log-level"); ok {
 		j.Context = j.Context.WithDBLogLevel(dbLevel)