My processor is successfully writing to my destination, but the write stats are not updated.
[image: image.png] I think the relevant code in my transform method is: failed_batches = self.write_to_vastdb(context, session, pa_table) if len(failed_batches) == 0: return FlowFileTransformResult(relationship = "success") else: return FlowFileTransformResult( relationship = "failure", content=json.dumps(failed_batches) ) Thanks!