"""Unit tests for Source of Stream Pre-aggregation Workflow."""