Skip to content
This repository has been archived by the owner on Oct 9, 2023. It is now read-only.

Commit

Permalink
nit
Browse files Browse the repository at this point in the history
Signed-off-by: Kevin Su <[email protected]>
  • Loading branch information
pingsutw committed Aug 20, 2023
1 parent 1a990ab commit 9fc638d
Showing 1 changed file with 2 additions and 7 deletions.
9 changes: 2 additions & 7 deletions go/tasks/plugins/webapi/agent/integration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -116,16 +116,11 @@ func TestEndToEnd(t *testing.T) {

phase := tests.RunPluginEndToEndTest(t, plugin, &template, inputs, nil, nil, iter)
assert.Equal(t, true, phase.Phase().IsSuccess())
})

t.Run("run a job that produces file output", func(t *testing.T) {
pluginEntry := pluginmachinery.CreateRemotePlugin(newMockAgentPlugin())
plugin, err := pluginEntry.LoadPlugin(context.TODO(), newFakeSetupContext("test2"))
assert.NoError(t, err)

template.Type = "spark_job"
phase := tests.RunPluginEndToEndTest(t, plugin, &template, inputs, nil, nil, iter)
phase = tests.RunPluginEndToEndTest(t, plugin, &template, inputs, nil, nil, iter)
assert.Equal(t, true, phase.Phase().IsSuccess())

})

t.Run("failed to create a job", func(t *testing.T) {
Expand Down

0 comments on commit 9fc638d

Please sign in to comment.