ray.data.Datasink.on_write_failed

Datasink.on_write_failed(error: Exception) → None

Callback for when a write job fails.

This is called on a best-effort basis on write failures.

Parameters:

error – The first error encountered.