cpdflow.lifecycle.subscribe.operate

class operate[source]

Bases: object

Handles delete and apply commands.

Methods

apply

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

delete

Remove subscriptions specified in model_configs.
static apply(config: dict, model_names: list) → None[source]

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

static delete(config: dict, model_names: list) → None[source]

Remove subscriptions 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