ray.data.Datasource.on_write_start

Datasource.on_write_start(**write_args) → 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.

Parameters

write_args – Additional kwargs to pass to the datasource impl.