770
}
771
772
>
func (d *namespaceHandler) removeOldestExpiredWorkflowRule(nsName string, rules map[string]*rulespb.WorkflowRule) {
namespace_handler.go
773
>
oldestTime := d.timeSource.Now()
774
>
var oldestKey string
775
>
found := false
776
>
777
>
for key, rule := range rules {
778
>
expirationTime := rule.GetSpec().GetExpirationTime()
779
>
if expirationTime == nil {
780
>
continue
781
}
783
>
oldestTime = expirationTime.AsTime()
784
>
oldestKey = key
785
>
found = true
786
>
}
787
}
788
790
>
d.logger.Info(
791
>
"Removed expired workflow rule",
792
>
tag.WorkflowRuleID(oldestKey),
793
>
tag.WorkflowNamespace(nsName),
794
>
)
795
>
delete(rules, oldestKey)
796
>
}
797
}
798