This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-api.git
The following commit(s) were added to refs/heads/main by this push:
new 9950e12 NIFI-14722 Added Registered Flow Snapshot Metadata to Process
Group Status (#8)
9950e12 is described below
commit 9950e126d36edaa9d568cb277d8c1c0ec55fd507
Author: Pierre Villard <[email protected]>
AuthorDate: Thu Jul 10 18:27:25 2025 +0200
NIFI-14722 Added Registered Flow Snapshot Metadata to Process Group Status
(#8)
Signed-off-by: David Handermann <[email protected]>
---
.../apache/nifi/controller/status/ProcessGroupStatus.java | 13 +++++++++++++
1 file changed, 13 insertions(+)
diff --git
a/src/main/java/org/apache/nifi/controller/status/ProcessGroupStatus.java
b/src/main/java/org/apache/nifi/controller/status/ProcessGroupStatus.java
index 7aaf6e7..9de9940 100644
--- a/src/main/java/org/apache/nifi/controller/status/ProcessGroupStatus.java
+++ b/src/main/java/org/apache/nifi/controller/status/ProcessGroupStatus.java
@@ -16,6 +16,7 @@
*/
package org.apache.nifi.controller.status;
+import org.apache.nifi.registry.flow.RegisteredFlowSnapshotMetadata;
import org.apache.nifi.registry.flow.VersionedFlowState;
import java.util.ArrayList;
@@ -28,7 +29,10 @@ public class ProcessGroupStatus implements Cloneable {
private String id;
private String name;
+
private VersionedFlowState versionedFlowState;
+ private RegisteredFlowSnapshotMetadata registeredFlowSnapshotMetadata;
+
private Integer inputCount;
private Long inputContentSize;
private Integer outputCount;
@@ -81,6 +85,14 @@ public class ProcessGroupStatus implements Cloneable {
this.versionedFlowState = versionedFlowState;
}
+ public RegisteredFlowSnapshotMetadata getRegisteredFlowSnapshotMetadata() {
+ return registeredFlowSnapshotMetadata;
+ }
+
+ public void
setRegisteredFlowSnapshotMetadata(RegisteredFlowSnapshotMetadata
registeredFlowSnapshotMetadata) {
+ this.registeredFlowSnapshotMetadata = registeredFlowSnapshotMetadata;
+ }
+
public Integer getInputCount() {
return inputCount;
}
@@ -462,6 +474,7 @@ public class ProcessGroupStatus implements Cloneable {
if
(VersionedFlowState.SYNC_FAILURE.equals(toMerge.getVersionedFlowState())) {
target.setVersionedFlowState(VersionedFlowState.SYNC_FAILURE);
}
+
target.setRegisteredFlowSnapshotMetadata(toMerge.getRegisteredFlowSnapshotMetadata());
// connection status
// sort by id
