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.

Parameters

Name	Type	Description
`object_fq_name`	`STRING`	The fully-qualified name of the source table or view in Snowflake, e.g. `'<db>.<schema>.<table_or_view>'`.
`model_name`	`STRING`	The 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