apr

apr

Hello!

I had a question regarding the usage of Multi.run/3. I am using pg as my database. Let’s say I have a Multi with a couple different updates to my db. At the very end, I want to run a custom function that does not update the db (so no Repo.insert etc. It updates an ets table) using Multi.run/3.

My question is, does it make sense to use Multi.run/3 to run functions that do not update the db? I would like to do this because my custom function can return {:error, value} and all the preceding updates can be rolled back.

Thanks!

Showing Posts 1 to 5

OvermindDL1

OvermindDL1

You use Multi.run for something not DB oriented but where you still want the DB to rollback if it fails, so yes, this is the use-case it is for. :slight_smile:

Just remember that an entire Multi pipeline is in a transaction, so the rows it accessed in the database are locked until it’s complete, so make sure it doesn’t take too long to run.

apr

apr OP

Gotcha! Thanks a lot @OvermindDL1!

Edit: I was also wondering, if you use a Multi.run to actually update the DB, does the update get rolled back when some other operation down the line fails? If so, how does Ecto figure out which Multi runs update the DB and which ones don’t (In order to rollback any updates on failure)?

benwilson512

benwilson512

Author of Craft GraphQL APIs in Elixir with Absinthe

@apr Ecto itself doesn’t “undo” the operations, rather it opens a transaction and then all operations within that transaction will be rolled back by the database unless the transaction is committed.

apr

apr OP

Cool. I understand now. Thanks Ben!

medikent

medikent

In order for an operation in a Multi.run block to be included in the transaction must the run block use the Repo argument passed from the earlier Multi step or can it call a function that makes arbitrary Repo calls while not using the repo passed in from the Multi? This could be such as calling Repo.one, Repo.insert, or something like that

— All posts loaded —

Where Next? Top

Trending in Questions Top

RSP87
I’m working on a project that simulates the bumbl example in the programming phoenix book. It acts almost like an email client. We have a...
New
kszambelanczyk
Hello! Could someone please give me a help/sample code, how to delete a file from s3 using waffle/waffle_ecto from Phoenix app. I creat...
New
RemyXRenard
I’m seeing that a list inside a Kino.DataTable will be interpreted as a charlist, even if the Kino.configure() is set to charlists: :as_l...
New
velrest
So my question is quite simple and i have found no conclusive answer on forum, google or AI. Should we use :erlang.float for Integer to ...
New
samoloth
Hi, I’ve just set up an application with ash_authentication. There is only magic link strategy for now, so there is no confirmation add o...
New
FlyingNoodle
If a change or preparation module uses Ash.Changeset.get_argument/2 or Ash.Query.get_argument/2 (or any of the other get_argument functio...
New
ryanwinchester
apply_graft/2 doesn’t rewrite an add_many sub-workflow’s deps on an add step. Grafted jobs cancel with “upstream job was deleted” Version...
New

Other Trending Topics Top

mudasobwa
I am happy to introduce the very α version of the new programming language compiled to BEAM. Welcome Cure. It has literally three kille...
New
garrison
Hobbes is a low-level distributed database for the Elixir programming language. Hobbes provides a simple, safe, and scalable storage lay...
New
marciok
Hi there! We created Gust: A task orchestrator inspired by Airflow. For those who have never heard about Aiflow, it’s a Python-based wor...
New
jimsynz
Beam Bots (or just BB for short) is a framework for building fault-tolerant robotics applications in Elixir using familiar OTP patterns. ...
New
Dmk
Xamal is a deployment tool for Elixir apps that deploys native releases to bare metal servers over SSH. It’s a port of GitHub - basecamp/...
New
Damirados
Hello everyone. After busy few months I am happy to announce v0.1.0 of Emerge & Solve. They are GUI (Emerge) and State management (S...
New

We're in Beta

About us Mission Statement

Options

Thread Display Mode




Thread Preview

Skip Thread Previews