ray.data.Datasink.on_write_complete#

Datasink.on_write_complete(write_result: WriteResult[WriteReturnType])[source]#

Callback for when a write job completes.

This can be used to commit a write output. This method must succeed prior to write_datasink() returning to the user. If this method fails, then on_write_failed() is called.

Parameters:

write_result – Aggregated result of the Write operator, containing write results and stats.