File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
misk-aws2-sqs/src/main/kotlin/misk/aws2/sqs/jobqueue Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -14,7 +14,6 @@ import misk.jobqueue.sqs.parentQueue
1414import misk.jobqueue.v2.JobEnqueuer
1515import misk.moshi.adapter
1616import misk.tokens.TokenGenerator
17- import software.amazon.awssdk.services.sqs.SqsAsyncClient
1817import software.amazon.awssdk.services.sqs.model.MessageAttributeValue
1918import software.amazon.awssdk.services.sqs.model.SendMessageRequest
2019import java.time.Clock
@@ -71,7 +70,7 @@ class SqsJobEnqueuer @Inject constructor(
7170 sqsMetrics.sqsSendTime.labels(queueName.value).observe((clock.millis() - startTime).toDouble())
7271 span.finish()
7372 scope.close()
74- }.thenCompose { CompletableFuture .supplyAsync { true } }
73+ }.thenApply { true }
7574 } catch (e: Exception ) {
7675 sqsMetrics.jobEnqueueFailures.labels(queueName.value).inc()
7776 throw e
You can’t perform that action at this time.
0 commit comments