alexcastano

alexcastano

Exclusive Periodic Task in Elixir Cluster

Hello,

I want to run a task every X minutes, but I’d like to be done only once. Because of this, I chose a solution using Genserver & Timeout, like this one: https://nesteryuk.info/2017/08/13/recurring-tasks-in-elixir-solution-2.html

I added this GenServer to my application tree with the name: {:global, __MODULE__}. This way avoid this task is executed each time in each cluster. After deploying, I saw a big problem. Only one node is alive because the other ones died trying to set up the periodic task which is impossible because is already registered in the alive node.

So I was thinking to check in the init function if the name has already been registered. In this case, it could return :ignore. But I see a big problem with this approach, if the whole node died unexpectly, the task won’t be executed again until a new node goes up. Not very resilient.

So, my main question is: if is there a simple way to achieve my goals or I should go with a more complex solution like using quantum?

PD: I like the GenServer solution because I can change the interval in runtime.

Thanks for your time

Marked As Solved

dom

dom

This does what you were trying to do: Singleton - global, supervised singleton processes for Elixir

The key is to do the name registration after the process starts, and then branch on the result:

  • If the registration succeeds, act as the “master”, running the periodic tasks
  • If it fails, then act as “follower” and just monitor the master. Once the master dies, try to take its place.

Where Next?

Popular in Questions Top

Darmani72
If I have a post route which an argument: post /my_post_route/:my_param1, MyController.my_post_handler How would get the post params ...
New
fireproofsocks
I’m working on defining a simple Ecto schema for a table (in PostGres), but I don’t see where I can define a column as NOT NULL. Conside...
New
stefanchrobot
What’s the safe way to decode a JSON string into a struct? I want to avoid calling String.to_atom. Jason.decode can give me a map with st...
New
belgoros
I’m not a pro in using Regex and can’t figure out why the following behaviour happens, especially if we take into account the difference ...
New
vonH
When I run the Plug and I recompile I wind up having to use Ctrl C to quit iex and start again. Witht the help of rlwrap I can use the cu...
New
JDanielMartinez
Hi! May someone helps me, please! I have two apps into an umbrella project: the first one is Database, which manages queries, and the se...
New
romenigld
I am trying to run a deploy with docker and I successfully runned with this command: docker build -t romenigld/blog-prod . but when I t...
New
shijith.k
I am trying to start a new phoenix project with elixir 1.9, but mix phx.new does not work. It says that ** (Mix) The task "phx.new" could...
New
lanycrost
Hi everyone! I need implement if…else if…else condition from my elixir code, and anymore of this control flow structures not work proper...
New
vonH
In asking this question I am more interested about the expressiveness of the language itself and less concerned about the availability of...
New

Other popular topics Top

danschultzer
None of the current solutions worked well for me, so I went ahead and built a user management system from scratch. This project took far...
548 29377 241
New
aadeshere1
I have a another noob question about loop. Since elixir is immutable, while loop is not directly possible. total = 10 while total != 0 ...
New
Patoshizzle
After calling mix ecto.create I get this error: 17:00:32.162 [error] GenServer #PID<0.412.0> terminating ** (Postgrex.Error) FATAL...
New
electic
Hi, I am new to Elixir. I am trying to use the DateTime component to insert a date into MySQL however the there seems to be no way to fo...
New
belgoros
I’m not a pro in using Regex and can’t figure out why the following behaviour happens, especially if we take into account the difference ...
New
sergio_101
I am VERY much an elixir newbie. I have taken one elixir course and one phoenix course on Udemy. During that course, I saw the instructor...
New
fayddelight
I tried installing elixir 1.11.2 erlang 23.3.4 via asdf in my zsh shell. Enabled the versions locally and globally. When I list them ...
New
boundedvariable
I am going through the kafka architecture. All the features what the kafka is providing are already in Erlang. I would like hear your opi...
New
PeterCarter
There are pre-rolled solutions for other frameworks that do work. However, Phoenix does not seem to have these. Have people had good expe...
New
svb
Hi! Currently I want to submit a form by pressing the Enter key. However, since my input field is of type “textarea” this is just adds a...
New

We're in Beta

About us Mission Statement