|
1 | 1 | package io.javaoperatorsdk.operator.processing.dependent.kubernetes;
|
2 | 2 |
|
3 |
| -import java.util.HashMap; |
4 |
| -import java.util.Optional; |
5 |
| -import java.util.Set; |
6 |
| - |
7 |
| -import org.slf4j.Logger; |
8 |
| -import org.slf4j.LoggerFactory; |
9 |
| - |
10 | 3 | import io.fabric8.kubernetes.api.model.HasMetadata;
|
| 4 | +import io.fabric8.kubernetes.api.model.Namespaced; |
11 | 5 | import io.fabric8.kubernetes.client.KubernetesClient;
|
12 | 6 | import io.fabric8.kubernetes.client.dsl.Resource;
|
13 | 7 | import io.javaoperatorsdk.operator.OperatorException;
|
|
27 | 21 | import io.javaoperatorsdk.operator.processing.event.source.SecondaryToPrimaryMapper;
|
28 | 22 | import io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource;
|
29 | 23 | import io.javaoperatorsdk.operator.processing.event.source.informer.Mappers;
|
| 24 | +import org.slf4j.Logger; |
| 25 | +import org.slf4j.LoggerFactory; |
| 26 | + |
| 27 | +import java.util.HashMap; |
| 28 | +import java.util.Optional; |
| 29 | +import java.util.Set; |
30 | 30 |
|
31 | 31 | @Ignore
|
32 | 32 | @Configured(by = KubernetesDependent.class, with = KubernetesDependentResourceConfig.class,
|
@@ -168,7 +168,11 @@ protected Resource<R> prepare(R desired, P primary, String actionName) {
|
168 | 168 | } else if (useDefaultAnnotationsToIdentifyPrimary()) {
|
169 | 169 | addDefaultSecondaryToPrimaryMapperAnnotations(desired, primary);
|
170 | 170 | }
|
171 |
| - return client.resource(desired).inNamespace(desired.getMetadata().getNamespace()); |
| 171 | + if (desired instanceof Namespaced) { |
| 172 | + return client.resource(desired).inNamespace(desired.getMetadata().getNamespace()); |
| 173 | + } else { |
| 174 | + return client.resource(desired); |
| 175 | + } |
172 | 176 | }
|
173 | 177 |
|
174 | 178 | @Override
|
|
0 commit comments