From d2f3dd75300cbca9f1e505d93059ab088806dc7b Mon Sep 17 00:00:00 2001 From: Chris Baker Date: Fri, 18 Jan 2019 20:00:19 +0000 Subject: [PATCH] documenting test for task runner failure to set TaskGroupName --- .../taskrunner/task_runner_test.go | 42 +++++++++++++++++++ 1 file changed, 42 insertions(+) diff --git a/client/allocrunner/taskrunner/task_runner_test.go b/client/allocrunner/taskrunner/task_runner_test.go index 5a409153b..875afe5fe 100644 --- a/client/allocrunner/taskrunner/task_runner_test.go +++ b/client/allocrunner/taskrunner/task_runner_test.go @@ -209,6 +209,48 @@ func TestTaskRunner_TaskEnv(t *testing.T) { assert.Equal(t, "global bar somebody", mockCfg.StdoutString) } +func TestTaskRunner_TaskConfig(t *testing.T) { + t.Parallel() + require := require.New(t) + + alloc := mock.BatchAlloc() + task := alloc.Job.TaskGroups[0].Tasks[0] + task.Driver = "mock_driver" + + //// Use interpolation from both node attributes and meta vars + //task.Config = map[string]interface{}{ + // "run_for": "1ms", + //} + + conf, cleanup := testTaskRunnerConfig(t, alloc, task.Name) + defer cleanup() + + // Run the first TaskRunner + tr, err := NewTaskRunner(conf) + require.NoError(err) + go tr.Run() + defer tr.Kill(context.Background(), structs.NewTaskEvent("cleanup")) + + // Wait for task to complete + select { + case <-tr.WaitCh(): + case <-time.After(3 * time.Second): + } + + // Get the mock driver plugin + driverPlugin, err := conf.DriverManager.Dispense(mockdriver.PluginID.Name) + require.NoError(err) + mockDriver := driverPlugin.(*mockdriver.Driver) + + // Assert its config has been properly interpolated + driverCfg, mockCfg := mockDriver.GetTaskConfig() + require.NotNil(driverCfg) + require.NotNil(mockCfg) + assert.Equal(t, alloc.Job.Name, driverCfg.JobName) + assert.Equal(t, alloc.TaskGroup, driverCfg.TaskGroupName) + assert.Equal(t, alloc.Job.TaskGroups[0].Tasks[0].Name, driverCfg.Name) +} + // Test that devices get sent to the driver func TestTaskRunner_DevicePropogation(t *testing.T) { t.Parallel()