Skip to content

relationalai.api.resume_data_stream()

resume_data_stream(object_fq_name STRING, model_name STRING)

Resumes a suspended or quarantined data stream for the specified RAI Python model. Requires the cdc_admin application role.

NameTypeDescription
object_fq_nameSTRINGThe fully-qualified name of the source table or view in Snowflake, e.g. '<db>.<schema>.<table_or_view>'.
model_nameSTRINGThe name of the model associated with the stream.

STRING

Use api.resume_data_stream() to resume a suspended or quarantined data stream for a RAI Python model.

-- Resume the data stream for the model 'MyModel'. Replace the placeholders with
-- your database, schema, and table or view name.
CALL relationalai.my_schema.resume_data_stream('<db>.<schema>.<table_or_view>', 'MyModel');
/*+---------------------+
| Data stream resumed |
+---------------------+ */

See Data Management for more information on data streams.