paper_firehose.core.command_utils

Shared utilities for command implementations.

Provides common patterns used across multiple commands.

Functions

resolve_topics(config_manager[, topic])

Resolve topic argument to list of topics to process.
paper_firehose.core.command_utils.resolve_topics(config_manager, topic=None)[source]

Resolve topic argument to list of topics to process.

If a specific topic is provided, returns a list containing just that topic. Otherwise, returns all available topics from the configuration.

Parameters:

  • config_manager (ConfigManager) – Configuration manager instance

  • topic (Optional[str]) – Optional specific topic name. If None, all topics are returned.

Return type:

List[str]

Returns:

List of topic names to process

Examples

>>> cfg = ConfigManager()
>>> resolve_topics(cfg, "physics")  # Returns ["physics"]
>>> resolve_topics(cfg, None)  # Returns all topics like ["physics", "biology", ...]