Skip to content

Commit a80aee8

Browse files
committed
reverts
Signed-off-by: Attila Mészáros <[email protected]>
1 parent 5b31592 commit a80aee8

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/AbstractEventSourceHolderDependentResource.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,10 +92,9 @@ public Class<R> resourceType() {
9292

9393
protected abstract T createEventSource(EventSourceContext<P> context);
9494

95-
public void setEventSource(T eventSource) {
95+
protected void setEventSource(T eventSource) {
9696
isCacheFillerEventSource = eventSource instanceof RecentOperationCacheFiller;
9797
this.eventSource = eventSource;
98-
applyFilters();
9998
}
10099

101100
protected void applyFilters() {

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/WorkflowReconcileExecutor.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -88,6 +88,7 @@ private <R> void registerOrDeregisterEventSourceBasedOnActivation(boolean activa
8888
var es = eventSource.orElseThrow();
8989
context.eventSourceRetriever()
9090
.dynamicallyRegisterEventSource(dependentResourceNode.getName(), es);
91+
9192
} else {
9293
context.eventSourceRetriever()
9394
.dynamicallyDeRegisterEventSource(dependentResourceNode.getName());

0 commit comments

Comments
 (0)