feat: improve dataplane transfer process logs (#4743)

* Improve dataplane transfer process logs. * Changes from PR.
eclipse-edc · Jan 20, 2025 · 446ff65 · 446ff65
1 parent a6e662a
commit 446ff65
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/...main/java/org/eclipse/edc/connector/dataplane/framework/pipeline/PipelineServiceImpl.java b/...main/java/org/eclipse/edc/connector/dataplane/framework/pipeline/PipelineServiceImpl.java
@@ -107,7 +107,8 @@ public CompletableFuture<StreamResult<Object>> transfer(DataFlowStartMessage req
 
         var source = sourceFactory.createSource(request);
         sources.put(request.getProcessId(), source);
-        monitor.debug(() -> format("Transferring from %s to %s.", request.getSourceDataAddress().getType(), request.getDestinationDataAddress().getType()));
+        monitor.debug(() -> format("Transferring from %s to %s for flow id: %s.",
+                request.getProcessId(), request.getSourceDataAddress().getType(), request.getDestinationDataAddress().getType()));
         return sink.transfer(source)
                 .thenApply(result -> {
                     terminate(request.getProcessId());
@@ -177,12 +178,14 @@ private DataSinkFactory getSinkFactory(DataFlowStartMessage request) {
 
     @NotNull
     private CompletableFuture<StreamResult<Object>> noSourceFactory(DataFlowStartMessage request) {
-        return completedFuture(StreamResult.error("Unknown data source type: " + request.getSourceDataAddress().getType()));
+        return completedFuture(StreamResult.error("Unknown data source type %s for flow id: %s.".formatted(
+                request.getProcessId(), request.getSourceDataAddress().getType())));
     }
 
     @NotNull
     private CompletableFuture<StreamResult<Object>> noSinkFactory(DataFlowStartMessage request) {
-        return completedFuture(StreamResult.error("Unknown data sink type: " + request.getDestinationDataAddress().getType()));
+        return completedFuture(StreamResult.error("Unknown data sink type %s for flow id: %s.".formatted(
+                request.getProcessId(), request.getDestinationDataAddress().getType())));
     }