fix: pass node-specific tracker prefix

Author: dkropachev

core/src/main/java/com/datastax/oss/driver/internal/core/cql/CqlRequestHandler.java

@@ -491,7 +491,7 @@ private void setFinalResult(
               nodeLatencyNanos,
               executionProfile,
               callback.node,
-              handlerLogPrefix);
+              callback.logPrefix);
           requestTracker.onSuccess(
               callback.statement,
               totalLatencyNanos,

core/src/test/java/com/datastax/oss/driver/internal/core/cql/CqlRequestHandlerTrackerTest.java

@@ -30,6 +30,8 @@
 import com.datastax.oss.driver.api.core.config.DriverExecutionProfile;
 import com.datastax.oss.driver.api.core.cql.AsyncResultSet;
 import com.datastax.oss.driver.api.core.servererrors.BootstrappingException;
+import com.datastax.oss.driver.api.core.session.Request;
+import com.datastax.oss.driver.api.core.tracker.RequestIdGenerator;
 import com.datastax.oss.driver.api.core.tracker.RequestTracker;
 import com.datastax.oss.driver.internal.core.tracker.NoopRequestTracker;
 import com.datastax.oss.protocol.internal.ProtocolConstants;
@@ -92,6 +94,61 @@ public void should_invoke_request_tracker() {
     }
   }
 
+  @Test
+  public void should_pass_node_specific_log_prefix_to_node_success_tracker() {
+    RequestIdGenerator requestIdGenerator =
+        new RequestIdGenerator() {
+          @Override
+          public String getSessionRequestId() {
+            return "session-id";
+          }
+
+          @Override
+          public String getNodeRequestId(Request request, String parentId) {
+            return "node-id";
+          }
+        };
+
+    try (RequestHandlerTestHarness harness =
+        RequestHandlerTestHarness.builder()
+            .withDefaultIdempotence(true)
+            .withRequestIdGenerator(requestIdGenerator)
+            .withResponse(node1, defaultFrameOf(singleRow()))
+            .build()) {
+
+      RequestTracker requestTracker = mock(RequestTracker.class);
+      when(harness.getContext().getRequestTracker()).thenReturn(requestTracker);
+
+      CompletionStage<AsyncResultSet> resultSetFuture =
+          new CqlRequestHandler(
+                  UNDEFINED_IDEMPOTENCE_STATEMENT,
+                  harness.getSession(),
+                  harness.getContext(),
+                  "test")
+              .handle();
+
+      assertThatStage(resultSetFuture)
+          .isSuccess(
+              resultSet -> {
+                verify(requestTracker)
+                    .onNodeSuccess(
+                        any(),
+                        anyLong(),
+                        any(DriverExecutionProfile.class),
+                        eq(node1),
+                        eq("test|node-id|0"));
+                verify(requestTracker)
+                    .onSuccess(
+                        any(),
+                        anyLong(),
+                        any(DriverExecutionProfile.class),
+                        eq(node1),
+                        eq("test|session-id"));
+                verifyNoMoreInteractions(requestTracker);
+              });
+    }
+  }
+
   @Test
   public void should_not_invoke_noop_request_tracker() {
     try (RequestHandlerTestHarness harness =