Function dataflow::source::s3::read_sqs_task

async fn read_sqs_task(
    source_id: String, 
    glob: Option<GlobMatcher>, 
    queue: String, 
    aws_config: AwsConfig, 
    tx: Sender<Result<KeyInfo, S3Error>>, 
    shutdown_rx: Receiver<DataflowStatus>, 
    base_metrics: SourceBaseMetrics
)