orangeqs.juice.client.topics#

Helpers for inspecting pub/sub topics active in a Juice instance.

Module Contents#

Functions#

get_topics_last_seen_timestamp

Get the pub/sub topics seen by the task manager.

API#

orangeqs.juice.client.topics.get_topics_last_seen_timestamp() → dict[str, str]#

Get the pub/sub topics seen by the task manager.

Returns a mapping of each unique topic to the timestamp (ISO 8601, UTC) it was last seen. Topics are tracked for the lifetime of the task manager process.

Returns#

  • (dict[str, str]): Mapping of topic to last seen timestamp.

Raises#

  • (RuntimeError): If the topic list could not be retrieved from the task manager.