Method buildUpdateCacheMemoryJobWrapper

pkg/workflow/compiler_jobs.go:380–405

buildUpdateCacheMemoryJobWrapper builds the update_cache_memory job if cache-memory is configured. Returns the job name if created, empty string otherwise.

(data *WorkflowData, threatDetectionEnabled bool)

// buildUpdateCacheMemoryJobWrapper builds the update_cache_memory job if cache-memory is configured.
// Returns the job name if created, empty string otherwise.
func (c *Compiler) buildUpdateCacheMemoryJobWrapper(data *WorkflowData, threatDetectionEnabled bool) (string, error) {
	if data.CacheMemoryConfig == nil || len(data.CacheMemoryConfig.Caches) == 0 {
		return "", nil
	}

	if !threatDetectionEnabled {
		return "", nil
	}

	compilerJobsLog.Print("Building update_cache_memory job")
	updateCacheMemoryJob, err := c.buildUpdateCacheMemoryJob(data, threatDetectionEnabled)
	if err != nil {
		return "", fmt.Errorf("failed to build update_cache_memory job: %w", err)
	}

	if updateCacheMemoryJob == nil {
		return "", nil
	}

	if err := c.jobManager.AddJob(updateCacheMemoryJob); err != nil {
		return "", fmt.Errorf("failed to add update_cache_memory job: %w", err)
	}

	compilerJobsLog.Printf("Successfully added update_cache_memory job: %s", updateCacheMemoryJob.Name)
	return updateCacheMemoryJob.Name, nil
}

// buildPushExperimentsStateJobWrapper builds the push_experiments_state job when experiments
// use repo-based storage.  Returns the job name if created, empty string otherwise.