schrodinger.stepper.cloud module

Public cloud related Stepper functions intended to be used outside the stepper module

schrodinger.stepper.cloud.get_all_topic_names(step: schrodinger.stepper.stepper._BaseStep) → Set[str]

Given a step, return a set of all the input and output topic names set on the PubSubEnabled steps

Parameters

step – the step to get all the topic names from

Returns

a set of all the input and output topic names

schrodinger.stepper.cloud.delete_all_topics(step: schrodinger.stepper.stepper._BaseStep)

Given a step, attempt to delete all the input and output topics used by the PubSubEnabled steps.

This is safe to call even if the given Step is not PubSubEnabled or is a Chain that contains no children that are PubSubEnabled.

Parameters

step – the step to delete all the topics