Commit d2883b95 authored by John McDonnell's avatar John McDonnell Committed by Ramya Authappan

Add health check for postgres in gitaly E2E

parent e8e46790
...@@ -174,7 +174,7 @@ module QA ...@@ -174,7 +174,7 @@ module QA
end end
def start_all_nodes def start_all_nodes
start_node(@postgres) start_postgres
start_node(@primary_node) start_node(@primary_node)
start_node(@secondary_node) start_node(@secondary_node)
start_node(@tertiary_node) start_node(@tertiary_node)
...@@ -183,6 +183,16 @@ module QA ...@@ -183,6 +183,16 @@ module QA
wait_for_health_check_all_nodes wait_for_health_check_all_nodes
end end
def start_postgres
start_node(@postgres)
Support::Waiter.repeat_until(max_attempts: 60, sleep_interval: 1) do
shell(sql_to_docker_exec_cmd("SELECT 1 as healthy_database"), fail_on_exception: false) do |line|
break true if line.include?("healthy_database")
end
end
end
def verify_storage_move(source_storage, destination_storage, repo_type: :project) def verify_storage_move(source_storage, destination_storage, repo_type: :project)
return if Specs::Helpers::ContextSelector.dot_com? return if Specs::Helpers::ContextSelector.dot_com?
......
...@@ -13,23 +13,25 @@ module QA ...@@ -13,23 +13,25 @@ module QA
# TODO, make it possible to use generic QA framework classes # TODO, make it possible to use generic QA framework classes
# as a library - gitlab-org/gitlab-qa#94 # as a library - gitlab-org/gitlab-qa#94
# #
def shell(command, stdin_data: nil) def shell(command, stdin_data: nil, fail_on_exception: true)
puts "Executing `#{command}`" puts "Executing `#{command}`"
Open3.popen2e(*command) do |stdin, out, wait| Open3.popen2e(*command) do |stdin, out, wait|
stdin.puts(stdin_data) if stdin_data stdin.puts(stdin_data) if stdin_data
stdin.close if stdin_data stdin.close if stdin_data
cmd_output = ''
if block_given? if block_given?
out.each do |line| out.each do |line|
cmd_output += line
yield line yield line
end end
end end
out.each_char { |char| print char } out.each_char { |char| print char }
if wait.value.exited? && wait.value.exitstatus.nonzero? if wait.value.exited? && wait.value.exitstatus.nonzero? && fail_on_exception
raise CommandError, "Command `#{command}` failed!" raise CommandError, "Command failed: #{command} \nCommand Output: #{cmd_output}"
end end
end end
end end
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment