I needed a method of manually clearing down PGs being used for automated
testing of flows, so I created a purge command in the Python client.
http://nipyapi.readthedocs.io/en/latest/_modules/nipyapi/canvas.html#purge_process_group
There's also an option to delete a process group with purge and a
Mike,
If you want to remove all FlowFiles from the flow, you could use the
REST api to get the list of all connections
(/controller/process-groups/root/status?recursive=true), and then issue the
command to "empty queue" (/flowfile-queues/{id}/drop-requests) on each of
them.
Brandon
On Tue,
Mike,
I don’t believe there are any APIs to perform that action. You could likely
achieve it by using an ExecuteStreamCommand processor and invoking “rm -rf
/path/to/flowfile_repository” but I’m not sure if that would cause an issue
given the triggering flowfile being executed at the time.
And
Are there any APIs that could be leveraged internally be a "reset"
processor to tell the flow file repository to purge everything?
Thanks,
Mike
