Function mz_storage::source::s3::process_message

async fn process_message(
    message: SqsMessage,
    glob: Option<&GlobMatcher>,
    base_metrics: SourceBaseMetrics,
    metrics: &mut BTreeMap<String, ScanBucketMetrics>,
    source_id: &str,
    tx: &Sender<Result<KeyInfo, S3Error>>,
    client: &SqsClient,
    queue_url: &str
) -> Option<(SqsMessage, String)>

Send the relevant parts of the message to the download objects task

Returns any message that wasn’t able to be processed to be released back to the SQS service, as well as the specific key that we failed to process from that message.