Function dataflow::source::s3::scan_bucket_task

async fn scan_bucket_task(
    bucket: String, 
    source_id: String, 
    glob: Option<GlobMatcher>, 
    aws_config: AwsConfig, 
    tx: Sender<Result<KeyInfo, S3Error>>, 
    base_metrics: SourceBaseMetrics
)