# File lib/rubyrep/replication_runner.rb, line 119 def execute_once session.refresh timeout = session.configuration.options[:database_connection_timeout] terminated = TaskSweeper.timeout(timeout) do |sweeper| run = ReplicationRun.new session, sweeper run.run end.terminated? raise "replication run timed out" if terminated rescue Exception => e clear_session raise e end