mirror of https://github.com/apache/nifi.git
NIFI-11064 Changed TestPutSFTP run iterations based on files queued
Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com> This closes #6863.
This commit is contained in:
parent
3fafb8798f
commit
7db6f17350
|
@ -222,9 +222,10 @@ class TestPutSFTP {
|
|||
secondAttributes.put(TRANSFER_HOST_ATTRIBUTE, LOCALHOST_ADDRESS);
|
||||
runner.enqueue(FLOW_FILE_CONTENTS, secondAttributes);
|
||||
|
||||
runner.run();
|
||||
final int flowFilesQueued = runner.getQueueSize().getObjectCount();
|
||||
runner.run(flowFilesQueued);
|
||||
|
||||
runner.assertTransferCount(PutSFTP.REL_SUCCESS, 2);
|
||||
runner.assertTransferCount(PutSFTP.REL_SUCCESS, flowFilesQueued);
|
||||
|
||||
final List<ProvenanceEventRecord> records = runner.getProvenanceEvents();
|
||||
|
||||
|
|
Loading…
Reference in New Issue