lordgamez commented on code in PR #1616:
URL: https://github.com/apache/nifi-minifi-cpp/pull/1616#discussion_r1275933970
##########
libminifi/src/core/ProcessSession.cpp:
##########
@@ -1147,4 +1147,8 @@ bool ProcessSession::existsFlowFileInRelationship(const
Relationship &relationsh
});
}
+bool ProcessSession::hasBeenTransferred(const core::FlowFile &flow) const {
+ return updated_relationships_.contains(flow.getUUID()) ||
added_flowfiles_.contains(flow.getUUID());
Review Comment:
Good catch, in `updated_relationships_` it didn't seem necessary as only
passed references were stored in hat map, but in `added_flowfiles_` there is a
separate state member for the relationship. Updated in
36eab99d6d2f0f9dcfedc0fcfee00ce1c1c414e4
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
