Provider.delete_stream()#
relationalai
#Provider.delete_stream(stream_id: str, model:str) -> None
Delete a stream from a model.
Requires the Snowflake user set in your configuration to have the cdc_admin application role.
Parameters#
| Name | Type | Description |
|---|---|---|
stream_id | str | The name of the stream to delete, e.g. "<db_name>.<schema_name>.<table_name>". |
model | str | Name of the model to delete the stream from. |
Returns#
None
Example#
Use .delete_stream() to delete a stream from a model:
#import relationalai as rai
app = rai.Provider()
app.delete_stream("my_db.my_schema.my_table", model="MyModel")
See Stream Management for details.