python processor not updating write stats

[chris snow]

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!