From 41b84c867c0268ab61cca0251b4f78f67984b5fc Mon Sep 17 00:00:00 2001 From: Anantha Kumaran Date: Mon, 6 Jul 2020 20:17:16 +0530 Subject: [PATCH] fix warnings --- lib/exq/dequeue/local.ex | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/exq/dequeue/local.ex b/lib/exq/dequeue/local.ex index c92293f2..0f4f0091 100644 --- a/lib/exq/dequeue/local.ex +++ b/lib/exq/dequeue/local.ex @@ -6,7 +6,7 @@ defmodule Exq.Dequeue.Local do end @impl true - def init(%{queue: queue}, options) do + def init(_, options) do {:ok, %State{max: Keyword.fetch!(options, :concurrency)}} end