Function dataflow::source::s3::download_objects_task

async fn download_objects_task(
    source_id: String, 
    rx: Receiver<Result<KeyInfo, S3Error>>, 
    tx: Sender<Result<InternalMessage, S3Error>>, 
    shutdown_rx: Receiver<DataflowStatus>, 
    aws_config: AwsConfig, 
    activator: SyncActivator, 
    compression: Compression, 
    metrics: SourceBaseMetrics
)