fix: do not overwrite the namespace

raystack · Nov 22, 2023 · 048f458 · 048f458
1 parent 47a6094
commit 048f458
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/modules/firehose/driver_plan.go b/modules/firehose/driver_plan.go
@@ -16,9 +16,7 @@ import (
 
 const SourceKafkaConsumerAutoOffsetReset = "SOURCE_KAFKA_CONSUMER_CONFIG_AUTO_OFFSET_RESET"
 
-var (
-	suffixRegex = regexp.MustCompile(`^([A-Za-z0-9-]+)-([0-9]+)$`)
-)
+var suffixRegex = regexp.MustCompile(`^([A-Za-z0-9-]+)-([0-9]+)$`)
 
 func (fd *firehoseDriver) Plan(_ context.Context, exr module.ExpandedResource, act module.ActionRequest) (*resource.Resource, error) {
 	switch act.Name {

diff --git a/modules/job/driver/plan.go b/modules/job/driver/plan.go
@@ -39,7 +39,6 @@ func (driver *Driver) planCreate(exr module.ExpandedResource, act module.ActionR
 }
 
 func (driver *Driver) planPendingWithConf(conf *config.Config, exr module.ExpandedResource, steps []PendingStep) (*resource.Resource, error) {
-	conf.Namespace = driver.Conf.Namespace
 	immediately := time.Now()
 	exr.Resource.Spec.Configs = modules.MustJSON(conf)
 	exr.Resource.State = resource.State{