cpdflow.lifecycle.subscribe.subscribe

subscribe(config: dict, model_names: list, space_type: str) → None

Remove, overwrite or create subscriptions that are specified in model_configs.

Handles the validate and operate lifecycle stages.

Parameters:

• config (dict) – configuration dictionary

• model_names (list[str]) – subscriptions to be removed, updated, overwritten or created