toniq
toniq copied to clipboard
joakimk
Simple and reliable background job processing library for Elixir.
When I am using toniq 1.2.0 with elixir 1.3.4, the following warning appears during compilation: ``` remote: warning: erlang:now/0: Deprecated BIF. See the "Time and Time Correction in Erlang" chapter...
Using toniq 1.2.0 ``` 2017-01-06T10:20:29.226317+00:00 app[web.1]: 10:20:29.215 [error] GenServer Toniq.JobImporter terminating 2017-01-06T10:20:29.226331+00:00 app[web.1]: ** (UndefinedFunctionError) function Toniq.JobImporter.terminate/2 is undefined or private 2017-01-06T10:20:29.226333+00:00 app[web.1]: (toniq) Toniq.JobImporter.terminate({:timeout, {:gen_server, :call, [#PID, {:request, [["*",...
When I am using toniq 1.2.0 with elixir 1.3.4, the following warning appears during compilation: ``` remote: warning: the variable "v1" is unsafe as it has been set inside a...
https://elixirforum.com/t/piping-toniq-jobs/2794/4 I'm trying to enqueue the same data structure to 2 different workers and it doesn't appear to work, apparently enqueue_to returns something different than what receives when everything works...
If a job crashes, I'd want to be notified via something like honeybadger or appsignal. Likewise if a job fails ultimately (no more retries). Is there somewhere to hook into...
First of all, thanks for toniq! It got me started on a project of mine. I was wondering if this line https://github.com/joakimk/toniq/blob/930f35f00a70550d00da0baee4243a5cf442c382/lib/toniq/job_concurrency_limiter.ex#L86 might be the cause for a big memory...
E.g. `Toniq.JobPersistence.store_incoming_job(Blah, [])`. As you likely catch this in your app's tests (I've only accidentally done this in iex), it's probably not a high proprity bug.
Hi, Would it be possible to add a notion of job priority when enqueuing a job ? There are many use cases where this would be very useful. Thanks.
Hi, I would like to implement mnesia support for toniq. Do you have any preference for how to add an extension point for a different backend? As far as I...
Hey! Looks like a cool library. As a minor quibble though about your readme example, you have ``` def perform(to: to, subject: subject, body: body) do # do work end...
