Fixes TestStreamIngestionWorker