Skip to content

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 19, 2023
1 parent 3e904de commit 1a990ab
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions go/tasks/plugins/webapi/agent/integration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -108,9 +108,9 @@ func TestEndToEnd(t *testing.T) {
},
}
basePrefix := storage.DataReference("fake://bucket/prefix/")
pluginEntry := pluginmachinery.CreateRemotePlugin(newMockAgentPlugin())

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

Expand All @@ -119,7 +119,8 @@ func TestEndToEnd(t *testing.T) {
})

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

template.Type = "spark_job"
Expand Down

0 comments on commit 1a990ab

Please sign in to comment.