diff --git a/pkg/eventemitter/azure_event_grid_topic_handler.go b/pkg/eventemitter/azure_event_grid_topic_handler.go index e249fe5def8..fd1cd2f7116 100644 --- a/pkg/eventemitter/azure_event_grid_topic_handler.go +++ b/pkg/eventemitter/azure_event_grid_topic_handler.go @@ -52,8 +52,8 @@ func NewAzureEventGridTopicHandler(context context.Context, clusterName string, switch podIdentity.Provider { case "", kedav1alpha1.PodIdentityProviderNone: - if authParams["key"] == "" { - err = fmt.Errorf("no key provided") + if authParams["azureEventGridAcceessKey"] == "" { + err = fmt.Errorf("no azure event grid access key provided") break } client, err = publisher.NewClientWithSharedKeyCredential(spec.Endpoint, azcore.NewKeyCredential(authParams["key"]), nil) diff --git a/tests/eventemitter/azureeventgridtopic/azureeventgridtopic_test.go b/tests/eventemitter/azureeventgridtopic/azureeventgridtopic_test.go index 7fad5a19ded..2c3660b841e 100644 --- a/tests/eventemitter/azureeventgridtopic/azureeventgridtopic_test.go +++ b/tests/eventemitter/azureeventgridtopic/azureeventgridtopic_test.go @@ -109,7 +109,7 @@ metadata: name: {{.SecretName}} namespace: {{.TestNamespace}} data: - key: {{.EventGridKey}} + azureEventGridAcceessKey: {{.EventGridKey}} ` triggerAuthTemplate = ` @@ -204,8 +204,6 @@ func testEventSourceEmitValue(t *testing.T, _ *kubernetes.Clientset, data templa // help function to load template data func getTemplateData() (templateData, []Template) { base64EventGridKey := base64.StdEncoding.EncodeToString([]byte(eventGridKey)) - fmt.Printf("eventGridKey: %s\n", eventGridKey) - fmt.Printf("base64EventGridKey: %s\n", base64EventGridKey) return templateData{ TestNamespace: namespace, ClientName: clientName,