From a36a10a5a989517ab3bb38078a333f099e13cb2d Mon Sep 17 00:00:00 2001 From: Bill Date: Tue, 30 Jul 2024 11:06:54 -0400 Subject: [PATCH] Add time outs to list_tables/2 --- lib/endo/adapters/postgres.ex | 4 ++-- mix.exs | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/endo/adapters/postgres.ex b/lib/endo/adapters/postgres.ex index d5be26c..4e33d3f 100644 --- a/lib/endo/adapters/postgres.ex +++ b/lib/endo/adapters/postgres.ex @@ -42,8 +42,8 @@ defmodule Endo.Adapters.Postgres do opts |> Table.query() - |> repo.all() - |> Task.async_stream(&(&1 |> repo.preload(preloads) |> derive_preloads.())) + |> repo.all(timeout: :timer.minutes(2)) + |> Task.async_stream(&(&1 |> repo.preload(preloads) |> derive_preloads.()), timeout: :timer.minutes(2)) |> Enum.map(fn {:ok, %Table{} = table} -> table end) end diff --git a/mix.exs b/mix.exs index ca0610d..abeced7 100644 --- a/mix.exs +++ b/mix.exs @@ -4,7 +4,7 @@ defmodule Endo.MixProject do def project do [ app: :endo, - version: "0.1.20", + version: "0.1.21", elixir: "~> 1.13", start_permanent: Mix.env() == :prod, deps: deps(),