I have a Lambda function that performs QLDB transactions. Because QLDB uses OCC (optimistic concurrency control), it’s necessary to add a SQS Fifo in front, making sure that potential conflicting transactions (in my case: transactions attached to a specific user) are processed in sequence.

Using the SQS SendMessage.waitForTaskToken can solve this problem, but it requires the use of multiple workflows.

Is it possible to add to a SQS and wait for the just-added message to be emitted from the SQS? I’m trying to avoid splitting this step function up.