From 9cdfb0d78c3673b0a2801c00a148dacb9dcd1b36 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Zolt=C3=A1n=20Papp?= <zoltan.pmail@gmail.com>
Date: Mon, 17 Nov 2025 11:45:12 +0100
Subject: [PATCH]  Handle unimplemented job type

---
 client/internal/engine.go  | 3 ++-
 client/jobexec/executor.go | 5 +++++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/client/internal/engine.go b/client/internal/engine.go
index 00c8cc10d..d96956ed3 100644
--- a/client/internal/engine.go
+++ b/client/internal/engine.go
@@ -1023,7 +1023,8 @@ func (e *Engine) receiveJobEvents() {
 				resp.WorkloadResults = bundleResult
 				return &resp
 			default:
-				return nil
+				resp.Reason = []byte(jobexec.ErrJobNotImplemented.Error())
+				return &resp
 			}
 		})
 		if err != nil {
diff --git a/client/jobexec/executor.go b/client/jobexec/executor.go
index 6d2146e68..3269bde61 100644
--- a/client/jobexec/executor.go
+++ b/client/jobexec/executor.go
@@ -2,6 +2,7 @@ package jobexec
 
 import (
 	"context"
+	"errors"
 	"fmt"
 
 	log "github.com/sirupsen/logrus"
@@ -10,6 +11,10 @@ import (
 	"github.com/netbirdio/netbird/upload-server/types"
 )
 
+var (
+	ErrJobNotImplemented = errors.New("job not implemented")
+)
+
 type Executor struct {
 }