Skip to content

Commit

Permalink
Add "" for audience
Browse files Browse the repository at this point in the history
  • Loading branch information
ReToCode committed Mar 19, 2024
1 parent 9b53a5f commit 95f02a5
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ func TestContainerSourceKafkaChannelKsvc(t *testing.T) {
ctx, env := defaultEnvironment(t)

createSubscriberFn := func(ref *duckv1.KReference, uri string) manifest.CfgFn {
return subscription.WithSubscriber(ref, uri)
return subscription.WithSubscriber(ref, uri, "")
}

since := time.Now()
Expand Down
4 changes: 2 additions & 2 deletions test/upgrade/upgrade_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -275,7 +275,7 @@ func inMemoryChannelTest(t *testing.T) {
channel_impl.EnvCfg.ChannelV = "v1"

createSubscriberFn := func(ref *duckv1.KReference, uri string) manifest.CfgFn {
return subscription.WithSubscriber(ref, uri)
return subscription.WithSubscriber(ref, uri, "")
}
env.Test(ctx, t, channel.ChannelChain(1, createSubscriberFn))
}
Expand Down Expand Up @@ -335,7 +335,7 @@ func kafkaChannelTest(t *testing.T) {
channel_impl.EnvCfg.ChannelV = "v1beta1"

createSubscriberFn := func(ref *duckv1.KReference, uri string) manifest.CfgFn {
return subscription.WithSubscriber(ref, uri)
return subscription.WithSubscriber(ref, uri, "")
}
env.Test(ctx, t, channel.ChannelChain(1, createSubscriberFn))
}
Expand Down

0 comments on commit 95f02a5

Please sign in to comment.