- def update(data_migration, params \\ %{}) do
- data_migration
- |> changeset(params)
- |> Repo.update()
- end
-
- def update_state(data_migration, new_state) do
- update(data_migration, %{state: new_state})
+ def update_one_by_id(id, params \\ %{}) do
+ with {1, _} <-
+ from(dm in DataMigration, where: dm.id == ^id)
+ |> Repo.update_all(set: params) do
+ :ok
+ end