From 233134c0bcd15929059ed5f544d95aac697eab69 Mon Sep 17 00:00:00 2001 From: russell Date: Tue, 13 May 2025 11:19:21 -0700 Subject: [PATCH] [sqs] handle un-fifo-ifying a sink's queue --- lib/sequin/consumers/sqs_sink.ex | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/lib/sequin/consumers/sqs_sink.ex b/lib/sequin/consumers/sqs_sink.ex index b8bd8d231..522257e10 100644 --- a/lib/sequin/consumers/sqs_sink.ex +++ b/lib/sequin/consumers/sqs_sink.ex @@ -54,11 +54,8 @@ defmodule Sequin.Consumers.SqsSink do end defp put_is_fifo(changeset) do - if changeset |> get_field(:queue_url) |> ends_with_fifo?() do - put_change(changeset, :is_fifo, true) - else - changeset - end + is_fifo = changeset |> get_field(:queue_url) |> ends_with_fifo?() + put_change(changeset, :is_fifo, is_fifo) end defp ends_with_fifo?(nil), do: false