fix

open-telemetry · Jan 20, 2025 · 4b1c4b6 · 4b1c4b6
1 parent 13ae4fb
commit 4b1c4b6
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 4 deletions.
diff --git a/...ources/src/main/java/io/opentelemetry/contrib/azure/resource/AzureVmResourceProvider.java b/...ources/src/main/java/io/opentelemetry/contrib/azure/resource/AzureVmResourceProvider.java
@@ -88,22 +88,31 @@ public int order() {
   }
 
   @Override
+  @SuppressWarnings("SystemOut")
   public Resource createResource(ConfigProperties config) {
-    return client
-        .get()
+    System.out.println("AzureVmResourceProvider.createResource");
+    Optional<String> optional = client.get();
+    System.out.println("optional.isPresent: " + optional.isPresent());
+    System.out.println("optional: " + optional);
+    return optional
         .map(body -> parseMetadata(body, COMPUTE_MAPPING, AZURE_VM))
         .orElse(Resource.empty());
   }
 
+  @SuppressWarnings("SystemOut")
   static Resource parseMetadata(String body, Map<String, Entry> computeMapping, String platform) {
+    System.out.println("AzureVmResourceProvider.parseMetadata");
     AttributesBuilder builder = azureAttributeBuilder(platform);
     try (JsonParser parser = AzureMetadataService.JSON_FACTORY.createParser(body)) {
       parser.nextToken();
       parseResponse(parser, builder, computeMapping);
     } catch (IOException e) {
+      System.out.println(e.getMessage());
       logger.log(Level.FINE, "Can't get Azure VM metadata", e);
     }
-    return Resource.create(builder.build());
+    Attributes build = builder.build();
+    System.out.println("build: " + build);
+    return Resource.create(build);
   }
 
   @NotNull

diff --git a/.../test/java/io/opentelemetry/contrib/azure/resource/MetadataBasedResourceProviderTest.java b/.../test/java/io/opentelemetry/contrib/azure/resource/MetadataBasedResourceProviderTest.java
@@ -27,8 +27,12 @@
 import org.jetbrains.annotations.NotNull;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.RegisterExtension;
+import org.junit.jupiter.api.parallel.Execution;
+import org.junit.jupiter.api.parallel.ExecutionMode;
 
+@Execution(ExecutionMode.SAME_THREAD)
 public abstract class MetadataBasedResourceProviderTest {
+
   @RegisterExtension
   public static final MockWebServerExtension server = new MockWebServerExtension();
 
@@ -50,7 +54,11 @@ private AttributesAssert createResource(Supplier<Optional<String>> client) {
     String response = client.get().orElse(null);
     System.out.println("response: " + response);
     client = () -> Optional.ofNullable(response);
-    Resource resource = getResourceProvider(client).createResource(null);
+    ResourceProvider resourceProvider = getResourceProvider(client);
+    System.out.println("resourceProvider: " + resourceProvider);
+    Resource resource = resourceProvider.createResource(null);
+    System.out.println("resource: " + resource);
+    System.out.println("resource.getAttributes(): " + resource.getAttributes());
     return OpenTelemetryAssertions.assertThat(resource.getAttributes());
   }