ray.data.Datasource.on_write_start#

Datasource.on_write_start(**write_args) None[source]#

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.

Warning

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