Unicorn + Octopus + preload_app = ActiveRecord::ConnectionNotEstablished about octopus

[sobrinho]

I think the same approach of #55 will work for unicorn:

before_fork do |server, worker|
  ActiveRecord::Base.connection_proxy.instance_variable_get(:@shards).each do |shard, connection_pool|
    connection_pool.disconnect!
  end
end

But I tested on unicorn 4.4.0 and it worked fine without defining any hook.

Maybe it's not necessary anymore or something on octopus master fixed that.

Closing :)

[damhonglinh]

I think solution from here #319 (comment) is more refreshed.

[alxgsv]

Here is my after_fork:

after_fork do |server, worker|
  defined?(ActiveRecord::Base) and ActiveRecord::Base.establish_connection
end

Maybe it is incorrect to reconnect to db with octopus in this way?

[alxgsv]

In another words my question is:

How to correctly disconnect and connect to database when using octopus?

Thanks.

[alxgsv]

This workaround helped me:

after_fork do |server, worker|
    Octopus.config["production"]["master"] = ActiveRecord::Base.connection.config
    ActiveRecord::Base.connection.initialize_shards(Octopus.config)
end

How correct is it? (In case that I use unicorn only in production)

[thiagopradi]

Maybe you need to initialize all shards before running, try to use this fix:

after_fork do |server, worker|
ActiveRecord::Base.connection_proxy.instance_variable_get(:@shards).each {|k,v| v.clear_reloadable_connections! }
end

[thiagopradi]

of course, shards not using capital letter

[brlo]

Refresh solution:

unicorn.rb:

before_fork do |server, worker|
  # the following is highly recommended for Rails + "preload_app true"
  # as there's no need for the master process to hold a connection
  if defined?(ActiveRecord::Base)
    ActiveRecord::Base.connection.disconnect!
    ActiveRecord::Base.connection_proxy.shards.each { |s,pool| pool.disconnect! }
  end
end

after_fork do |server, worker|
  if defined?(ActiveRecord::Base)
    ActiveRecord::Base.connection_proxy.shards.each do |s,pool|
      pool.clear_reloadable_connections!
    end
  end
end