From f301affdd0cbe3884cc68adc9d83d18eb0baad56 Mon Sep 17 00:00:00 2001 From: Renan DelValle Date: Mon, 18 Sep 2017 16:10:10 -0700 Subject: [PATCH] Initializing CPU, RAM, and DISK resources to have an address when a new job object is created so that were able to modify the values when constructing job updates. --- job.go | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/job.go b/job.go index 8656556..f1d57e7 100644 --- a/job.go +++ b/job.go @@ -87,6 +87,11 @@ func NewJob() Job { taskConfig.Resources[ramMb] = true taskConfig.Resources[diskMb] = true + + numCpus.NumCpus = new(float64) + ramMb.RamMb = new(int64) + diskMb.DiskMb = new(int64) + return &AuroraJob{jobConfig, resources, 0} } @@ -136,21 +141,23 @@ func (j *AuroraJob) ExecutorData(data string) Job { } func (j *AuroraJob) CPU(cpus float64) Job { - j.resources["cpu"].NumCpus = &cpus + *j.resources["cpu"].NumCpus = cpus j.jobConfig.TaskConfig.NumCpus = cpus //Will be deprecated soon return j } func (j *AuroraJob) RAM(ram int64) Job { - j.resources["ram"].RamMb = &ram + *j.resources["ram"].RamMb = ram j.jobConfig.TaskConfig.RamMb = ram //Will be deprecated soon + + return j } func (j *AuroraJob) Disk(disk int64) Job { - j.resources["disk"].DiskMb = &disk + *j.resources["disk"].DiskMb = disk j.jobConfig.TaskConfig.DiskMb = disk //Will be deprecated return j