ray.data.Datasink.on_write_complete#
- Datasink.on_write_complete(write_results: List[Any]) None [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, thenon_write_failed()
is called.- Parameters:
write_results – The objects returned by every
write()
task.