TODO: Available commands
stream-processorStarts the Pulsar consumer and processes frames.
stream-processor cleanupRuns a single cleanup cycle. Useful for CronJob deployments.
# Continuous mode
stream-processor offline-checker --continuous
# One-shot mode
stream-processor offline-checker --oncestream-processor archive-cleanupRemoves expired archives.
src/stream_processor/main.py