fix

Author: trask

instrumentation/powerjob-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/powerjob/v4_0/PowerJobBasicProcessorTest.java

@@ -176,34 +176,26 @@ void testMapReduceProcessor() throws Exception {
         });
   }
 
-  // ShellProcessor relies on /bin/sh so skip on Windows where that binary is unavailable.
   @DisabledOnOs(value = OS.WINDOWS, disabledReason = "ShellProcessor requires /bin/sh")
   @Test
   void testShellProcessor() throws Exception {
     long jobId = 1;
-    // echo works on both Linux and Windows
-    String jobParam = "echo test";
+    String jobParam = "ls";
     TaskContext taskContext = genTaskContext(jobId, jobParam);
     taskContext.setWorkflowContext(new WorkflowContext(jobId, ""));
     taskContext.setOmsLogger(new TestOmsLogger());
     BasicProcessor shellProcessor = new ShellProcessor();
-    Class<?> shellProcessorClass = shellProcessor.getClass();
-    ProcessResult result = shellProcessor.process(taskContext);
-    assertThat(result.isSuccess())
-        .as(
-            "shell processor result on %s: %s",
-            System.getProperty("os.name"), result.getMsg())
-        .isTrue();
+    shellProcessor.process(taskContext);
     testing.waitAndAssertTraces(
         trace -> {
           trace.hasSpansSatisfyingExactly(
               span -> {
-                span.hasName(String.format("%s.process", shellProcessorClass.getSimpleName()))
+                span.hasName(String.format("%s.process", ShellProcessor.class.getSimpleName()))
                     .hasKind(SpanKind.INTERNAL)
                     .hasStatus(StatusData.unset())
                     .hasAttributesSatisfyingExactly(
                         attributeAssertions(
-                            shellProcessorClass.getName(), jobId, jobParam, SHELL_PROCESSOR));
+                            ShellProcessor.class.getName(), jobId, jobParam, SHELL_PROCESSOR));
               });
         });
   }

instrumentation/reactor/reactor-netty/reactor-netty-0.9/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/reactornetty/v0_9/ReactorNettyHttpClientTest.java

@@ -46,9 +46,10 @@ protected void configure(HttpClientTestOptions.Builder optionsBuilder) {
       optionsBuilder.setTestRemoteConnection(false);
     }
 
-    // Disable single connection tests on Windows due to networking stack differences
-    optionsBuilder.setSingleConnectionFactory(
-        isWindows ? (host, port) -> null : ReactorNettyHttpClientTest::createSingleConnection);
+    // Only run single connection tests on Linux due to networking stack differences
+    if (!isWindows) {
+      optionsBuilder.setSingleConnectionFactory(ReactorNettyHttpClientTest::createSingleConnection);
+    }
   }
 
   private static SingleConnection createSingleConnection(String host, int port) {

instrumentation/reactor/reactor-netty/reactor-netty-1.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/reactornetty/v1_0/ReactorNettyHttpClientTest.java

@@ -40,10 +40,8 @@ protected void configure(HttpClientTestOptions.Builder optionsBuilder) {
       optionsBuilder.setTestRemoteConnection(false);
     }
 
-    // Disable single connection tests on Windows due to networking stack differences
-    if (isWindows) {
-      optionsBuilder.setSingleConnectionFactory((host, port) -> null);
-    } else {
+    // Only run single connection tests on Linux due to networking stack differences
+    if (!isWindows) {
       optionsBuilder.setSingleConnectionFactory(
           (host, port) -> {
             HttpClient httpClient =