fix the propagation of Choice address
@@ -139,6 +139,8 @@ func (ps *ChoiceStatus) PropagateChannelStatuses(ingressChannel *duckv1alpha1.Ch
ps.IngressChannelStatus.ReadyCondition = apis.Condition{Type: apis.ConditionReady, Status: corev1.ConditionFalse, Reason: "NotAddressable", Message: "Channel is not addressable"}
allReady = false
}
+ // Propagate ingress channel address to Choice
+ ps.setAddress(address)
for i, c := range channels {
ps.CaseStatuses[i].FilterChannelStatus = ChoiceChannelStatus{
@@ -158,11 +160,6 @@ func (ps *ChoiceStatus) PropagateChannelStatuses(ingressChannel *duckv1alpha1.Ch
ps.CaseStatuses[i].FilterChannelStatus.ReadyCondition = apis.Condition{Type: apis.ConditionReady, Status: corev1.ConditionFalse, Reason: "NotAddressable", Message: "Channel is not addressable"}
allReady = false
}
-
- // Mark the Choice address as the Address of the first channel.
- if i == 0 {
- ps.setAddress(address)
- }
}
if allReady {
pChoiceCondSet.Manage(ps).MarkTrue(ChoiceConditionChannelsReady)
