Configure Job Clusters in Rift

When defining a Batch Feature View or a Stream Feature View using Rift, you can set the batch_compute parameter using the RiftBatchConfig object.

This configures the instance type of the job used to materialize to the online and/or offline store. This must be set to a valid EC2 instance type.

Example

from tecton import batch_feature_view, RiftBatchConfig


@batch_feature_view(
    batch_compute=RiftBatchConfig(
        instance_type="m5.2xlarge",
    ),
    ...,
)
def my_feature_view():
    return ...