Skip to content

Commit 732fb60

Browse files
fix timeout
1 parent 16cdfed commit 732fb60

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

lib/ecto/adapters/myxql.ex

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -561,8 +561,9 @@ defmodule Ecto.Adapters.MyXQL do
561561

562562
port_opts = port_opts(cmd_opts, args: args)
563563
port = Port.open({:spawn_executable, cmd}, port_opts)
564-
Port.command(port, contents)
565-
Port.command(port, "\n")
564+
IO.inspect port
565+
IO.inspect Port.command(port, contents)
566+
IO.inspect Port.command(port, "\n")
566567

567568
{initial, fun} = Collectable.into("")
568569

@@ -611,9 +612,8 @@ defmodule Ecto.Adapters.MyXQL do
611612
{^port, {:exit_status, status}} ->
612613
{acc, status}
613614

614-
{^port, other} ->
615-
IO.inspect other
616-
{acc, other}
615+
after
616+
1000 -> IO.puts("No messages")
617617
end
618618
end
619619
end

0 commit comments

Comments
 (0)