Function mz_storage::source::s3::download_objects_task

async fn download_objects_task(
    source_id: GlobalId,
    rx: Receiver<Result<KeyInfo, S3Error>>,
    tx: Sender<Result<Vec<u8>, S3Error>>,
    shutdown_rx: Receiver<DataflowStatus>,
    aws_config: AwsConfig,
    aws_external_id_prefix: Option<AwsExternalIdPrefix>,
    activator: SyncActivator,
    compression: Compression,
    metrics: SourceBaseMetrics,
    secrets_reader: Arc<dyn SecretsReader>
)