Hey Breandán, session.create() will create a brand new FlowFile, not retrieve one from the queue. I'd suggest session.get() if you're trying to retrieve incoming FlowFiles.
Thanks, Bryan On Thu, Sep 22, 2016 at 11:52 AM, Breandan Mac Parland < breandan.parl...@dbg.co.uk> wrote: > Hi, > > I have a simple workflow whereby a flowfile is passed into an > ExecuteScript processor. This runs the following python in the Script Body: > > ff = session.create() > session.transfer(ff, REL_SUCCESS) > > This transfers the flowfile to the success path, however, the flowfile is > never removed from the input queue and thus continues to execute again and > again. How do I remove it from the input queue once the script has run? > > p.s. Is there any documentation for this? Best I have found is the > (unofficial?) http://funnifi.blogspot.co.uk/2016/02/executescript- > processor-hello-world.html > > Cheers, > > Breandán >
