Datasource.on_write_complete(write_results: List[Any], **kwargs) 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_datasource() returning to the user. If this method fails, then on_write_failed() will be called.

  • write_results – The list of the write task results.

  • kwargs – Forward-compatibility placeholder.


DEPRECATED: This API is deprecated and may be removed in future Ray releases.