ray.data.Datasink.on_write_start

Datasink.on_write_start() → None

Callback for when a write job starts.

Use this method to perform setup for write tasks. For example, creating a staging bucket in S3.