Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion .tool-versions
Original file line number Diff line number Diff line change
@@ -1 +1,2 @@
elixir 1.8.1
erlang 23.0.2
elixir 1.10.4-otp-23
3 changes: 3 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,6 +1,9 @@
Changelog
=========

## Version 0.10.2

- [Enhancement] Remove useless ex utils

## Version 0.10.1

Expand Down
2 changes: 1 addition & 1 deletion lib/que/job.ex
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,7 @@ end

defimpl String.Chars, for: Que.Job do
def to_string(job) do
"Job # #{job.id} with #{ExUtils.Module.name(job.worker)}"
"Job # #{job.id} with #{job.worker |> Module.split |> Enum.join(".")}"
end
end

2 changes: 1 addition & 1 deletion lib/que/server.ex
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ defmodule Que.Server do

@doc false
def handle_call({:add_job, worker, args}, _from, queue) do
Que.Helpers.log("Queued new Job for #{ExUtils.Module.name(worker)}")
Que.Helpers.log("Queued new Job for #{worker |> Module.split |> Enum.join(".")}")

job =
worker
Expand Down
6 changes: 3 additions & 3 deletions lib/que/worker.ex
Original file line number Diff line number Diff line change
Expand Up @@ -177,7 +177,7 @@ defmodule Que.Worker do
if Que.Worker.valid?(module) do
:ok
else
raise Que.Error.InvalidWorker, "#{ExUtils.Module.name(module)} is an Invalid Worker"
raise Que.Error.InvalidWorker, "#{module |> Module.split |> Enum.join(".")} is an Invalid Worker"
end
end

Expand Down Expand Up @@ -224,14 +224,14 @@ defmodule Que.Worker do
# Raises error if the Worker doesn't export a perform/1 method
unless Module.defines?(__MODULE__, {:perform, 1}) do
raise Que.Error.InvalidWorker,
"#{ExUtils.Module.name(__MODULE__)} must export a perform/1 method"
"#{__MODULE__ |> Module.split |> Enum.join(".")} must export a perform/1 method"
end


# Raise error if the concurrency option in invalid
unless @concurrency == :infinity or (is_integer(@concurrency) and @concurrency > 0) do
raise Que.Error.InvalidWorker,
"#{ExUtils.Module.name(__MODULE__)} has an invalid concurrency value"
"#{__MODULE__ |> Module.split |> Enum.join(".")} has an invalid concurrency value"
end
end

Expand Down
3 changes: 1 addition & 2 deletions mix.exs
Original file line number Diff line number Diff line change
Expand Up @@ -43,15 +43,14 @@ defmodule Que.Mixfile do
def application do
[
mod: {Que, []},
applications: [:logger, :memento, :ex_utils]
applications: [:logger, :memento]
]
end


defp deps do
[
{:memento, "~> 0.3.0" },
{:ex_utils, "~> 0.1.6" },
{:ex_doc, ">= 0.0.0", only: :docs },
{:inch_ex, ">= 0.0.0", only: :docs },
]
Expand Down
17 changes: 8 additions & 9 deletions mix.lock
Original file line number Diff line number Diff line change
@@ -1,11 +1,10 @@
%{
"earmark": {:hex, :earmark, "1.3.2", "b840562ea3d67795ffbb5bd88940b1bed0ed9fa32834915125ea7d02e35888a5", [:mix], [], "hexpm"},
"ex_doc": {:hex, :ex_doc, "0.20.2", "1bd0dfb0304bade58beb77f20f21ee3558cc3c753743ae0ddbb0fd7ba2912331", [:mix], [{:earmark, "~> 1.3", [hex: :earmark, repo: "hexpm", optional: false]}, {:makeup_elixir, "~> 0.10", [hex: :makeup_elixir, repo: "hexpm", optional: false]}], "hexpm"},
"ex_utils": {:hex, :ex_utils, "0.1.6", "1284bbc05fe7ba917910f9a4c741696806af3ca2b971f678d4a6233c596af689", [:mix], [], "hexpm"},
"inch_ex": {:hex, :inch_ex, "0.5.6", "418357418a553baa6d04eccd1b44171936817db61f4c0840112b420b8e378e67", [:mix], [{:poison, "~> 1.5 or ~> 2.0 or ~> 3.0", [hex: :poison, repo: "hexpm", optional: false]}], "hexpm"},
"makeup": {:hex, :makeup, "0.8.0", "9cf32aea71c7fe0a4b2e9246c2c4978f9070257e5c9ce6d4a28ec450a839b55f", [:mix], [{:nimble_parsec, "~> 0.5.0", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm"},
"makeup_elixir": {:hex, :makeup_elixir, "0.13.0", "be7a477997dcac2e48a9d695ec730b2d22418292675c75aa2d34ba0909dcdeda", [:mix], [{:makeup, "~> 0.8", [hex: :makeup, repo: "hexpm", optional: false]}], "hexpm"},
"memento": {:hex, :memento, "0.3.0", "6a7a4fee282b424006bd92817f994a3c28fc807d8deb7ea0e29b5d01ca81a12b", [:mix], [], "hexpm"},
"nimble_parsec": {:hex, :nimble_parsec, "0.5.0", "90e2eca3d0266e5c53f8fbe0079694740b9c91b6747f2b7e3c5d21966bba8300", [:mix], [], "hexpm"},
"poison": {:hex, :poison, "3.1.0", "d9eb636610e096f86f25d9a46f35a9facac35609a7591b3be3326e99a0484665", [:mix], [], "hexpm"},
"earmark": {:hex, :earmark, "1.3.2", "b840562ea3d67795ffbb5bd88940b1bed0ed9fa32834915125ea7d02e35888a5", [:mix], [], "hexpm", "e3be2bc3ae67781db529b80aa7e7c49904a988596e2dbff897425b48b3581161"},
"ex_doc": {:hex, :ex_doc, "0.20.2", "1bd0dfb0304bade58beb77f20f21ee3558cc3c753743ae0ddbb0fd7ba2912331", [:mix], [{:earmark, "~> 1.3", [hex: :earmark, repo: "hexpm", optional: false]}, {:makeup_elixir, "~> 0.10", [hex: :makeup_elixir, repo: "hexpm", optional: false]}], "hexpm", "8e24fc8ff9a50b9f557ff020d6c91a03cded7e59ac3e0eec8a27e771430c7d27"},
"inch_ex": {:hex, :inch_ex, "0.5.6", "418357418a553baa6d04eccd1b44171936817db61f4c0840112b420b8e378e67", [:mix], [{:poison, "~> 1.5 or ~> 2.0 or ~> 3.0", [hex: :poison, repo: "hexpm", optional: false]}], "hexpm", "7123ca0450686a61416a06cd38e26af18fd0f8c1cff5214770a957c6e0724338"},
"makeup": {:hex, :makeup, "0.8.0", "9cf32aea71c7fe0a4b2e9246c2c4978f9070257e5c9ce6d4a28ec450a839b55f", [:mix], [{:nimble_parsec, "~> 0.5.0", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "5fbc8e549aa9afeea2847c0769e3970537ed302f93a23ac612602e805d9d1e7f"},
"makeup_elixir": {:hex, :makeup_elixir, "0.13.0", "be7a477997dcac2e48a9d695ec730b2d22418292675c75aa2d34ba0909dcdeda", [:mix], [{:makeup, "~> 0.8", [hex: :makeup, repo: "hexpm", optional: false]}], "hexpm", "adf0218695e22caeda2820eaba703fa46c91820d53813a2223413da3ef4ba515"},
"memento": {:hex, :memento, "0.3.0", "6a7a4fee282b424006bd92817f994a3c28fc807d8deb7ea0e29b5d01ca81a12b", [:mix], [], "hexpm", "6edbd94cd02360f1c6abaae2e84f19d12f64ca55b87dd82abb5d3d97f6100624"},
"nimble_parsec": {:hex, :nimble_parsec, "0.5.0", "90e2eca3d0266e5c53f8fbe0079694740b9c91b6747f2b7e3c5d21966bba8300", [:mix], [], "hexpm", "5c040b8469c1ff1b10093d3186e2e10dbe483cd73d79ec017993fb3985b8a9b3"},
"poison": {:hex, :poison, "3.1.0", "d9eb636610e096f86f25d9a46f35a9facac35609a7591b3be3326e99a0484665", [:mix], [], "hexpm", "fec8660eb7733ee4117b85f55799fd3833eb769a6df71ccf8903e8dc5447cfce"},
}