resume_data_stream()#

relationalai.api
#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.

Parameters#

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.

Returns#

STRING

Example#

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.

See Also#