feat: should not create dlq job with empty image and prom host

internal/server/v1/dlq/errors.go

@@ -6,4 +6,6 @@ var (
 	ErrFirehoseNamespaceNotFound = errors.New("could not find firehose namespace from resource output")
 	ErrFirehoseNamespaceInvalid  = errors.New("invalid firehose namespace from resource output")
 	ErrFirehoseNotFound          = errors.New("firehose not found")
+	ErrEmptyConfigImage          = errors.New("empty dlq job image")
+	ErrEmptyConfigPrometheusHost = errors.New("empty prometheus host")
 )

internal/server/v1/dlq/service.go

@@ -36,6 +36,13 @@ func NewService(client entropyv1beta1rpc.ResourceServiceClient, gcsClient gcs.Bl
 
 // TODO: replace *DlqJob with a generated models.DlqJob
 func (s *Service) CreateDLQJob(ctx context.Context, userEmail string, dlqJob models.DlqJob) (models.DlqJob, error) {
+	if s.cfg.DlqJobImage == "" {
+		return models.DlqJob{}, ErrEmptyConfigImage
+	}
+	if s.cfg.PrometheusHost == "" {
+		return models.DlqJob{}, ErrEmptyConfigPrometheusHost
+	}
+
 	dlqJob.Replicas = 1
 
 	def, err := s.client.GetResource(ctx, &entropyv1beta1.GetResourceRequest{Urn: dlqJob.ResourceID})