Skip to content

Commit 4b1c4b6

Browse files
committed
fix
1 parent 13ae4fb commit 4b1c4b6

File tree

2 files changed

+21
-4
lines changed

2 files changed

+21
-4
lines changed

azure-resources/src/main/java/io/opentelemetry/contrib/azure/resource/AzureVmResourceProvider.java

Lines changed: 12 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -88,22 +88,31 @@ public int order() {
8888
}
8989

9090
@Override
91+
@SuppressWarnings("SystemOut")
9192
public Resource createResource(ConfigProperties config) {
92-
return client
93-
.get()
93+
System.out.println("AzureVmResourceProvider.createResource");
94+
Optional<String> optional = client.get();
95+
System.out.println("optional.isPresent: " + optional.isPresent());
96+
System.out.println("optional: " + optional);
97+
return optional
9498
.map(body -> parseMetadata(body, COMPUTE_MAPPING, AZURE_VM))
9599
.orElse(Resource.empty());
96100
}
97101

102+
@SuppressWarnings("SystemOut")
98103
static Resource parseMetadata(String body, Map<String, Entry> computeMapping, String platform) {
104+
System.out.println("AzureVmResourceProvider.parseMetadata");
99105
AttributesBuilder builder = azureAttributeBuilder(platform);
100106
try (JsonParser parser = AzureMetadataService.JSON_FACTORY.createParser(body)) {
101107
parser.nextToken();
102108
parseResponse(parser, builder, computeMapping);
103109
} catch (IOException e) {
110+
System.out.println(e.getMessage());
104111
logger.log(Level.FINE, "Can't get Azure VM metadata", e);
105112
}
106-
return Resource.create(builder.build());
113+
Attributes build = builder.build();
114+
System.out.println("build: " + build);
115+
return Resource.create(build);
107116
}
108117

109118
@NotNull

azure-resources/src/test/java/io/opentelemetry/contrib/azure/resource/MetadataBasedResourceProviderTest.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,12 @@
2727
import org.jetbrains.annotations.NotNull;
2828
import org.junit.jupiter.api.Test;
2929
import org.junit.jupiter.api.extension.RegisterExtension;
30+
import org.junit.jupiter.api.parallel.Execution;
31+
import org.junit.jupiter.api.parallel.ExecutionMode;
3032

33+
@Execution(ExecutionMode.SAME_THREAD)
3134
public abstract class MetadataBasedResourceProviderTest {
35+
3236
@RegisterExtension
3337
public static final MockWebServerExtension server = new MockWebServerExtension();
3438

@@ -50,7 +54,11 @@ private AttributesAssert createResource(Supplier<Optional<String>> client) {
5054
String response = client.get().orElse(null);
5155
System.out.println("response: " + response);
5256
client = () -> Optional.ofNullable(response);
53-
Resource resource = getResourceProvider(client).createResource(null);
57+
ResourceProvider resourceProvider = getResourceProvider(client);
58+
System.out.println("resourceProvider: " + resourceProvider);
59+
Resource resource = resourceProvider.createResource(null);
60+
System.out.println("resource: " + resource);
61+
System.out.println("resource.getAttributes(): " + resource.getAttributes());
5462
return OpenTelemetryAssertions.assertThat(resource.getAttributes());
5563
}
5664

0 commit comments

Comments
 (0)