fix error

Signed-off-by: Nelson Chen <asd3431090@gmail.com>

flyteplugins/go/tasks/pluginmachinery/flytek8s/pod_helper_test.go

@@ -54,6 +54,8 @@ func dummyTaskExecutionMetadata(resources *v1.ResourceRequirements, extendedReso
 	to.On("GetResources").Return(resources)
 	to.On("GetExtendedResources").Return(extendedResources)
 	to.On("GetContainerImage").Return(containerImage)
+	to.On("GetAnnotations").Return(map[string]string{"annotation-1": "val1"})
+	to.On("GetLabels").Return(map[string]string{"label-1": "val1"})
 	taskExecutionMetadata.On("GetOverrides").Return(to)
 	taskExecutionMetadata.On("IsInterruptible").Return(true)
 	taskExecutionMetadata.OnGetPlatformResources().Return(&v1.ResourceRequirements{})

flyteplugins/tests/end_to_end.go

@@ -148,6 +148,8 @@ func RunPluginEndToEndTest(t *testing.T, executor pluginCore.Plugin, template *i
 	})
 	overrides.OnGetExtendedResources().Return(&idlCore.ExtendedResources{})
 	overrides.OnGetContainerImage().Return("")
+	overrides.OnGetAnnotations().Return(map[string]string{})
+	overrides.OnGetLabels().Return(map[string]string{})
 
 	tMeta := &coreMocks.TaskExecutionMetadata{}
 	tMeta.OnGetTaskExecutionID().Return(tID)

flytepropeller/pkg/apis/flyteworkflow/v1alpha1/iface.go

@@ -442,7 +442,7 @@ type ExecutableNode interface {
 	GetActiveDeadline() *time.Duration
 	IsInterruptible() *bool
 	GetName() string
-	GetContainerImage()
+	GetContainerImage() string
 	GetAnnotations() map[string]string
 	GetLabels() map[string]string
 }