# File lib/dynflow/coordinator_adapters/sequel.rb, line 4 def initialize(world) super @sequel_adapter = world.persistence.adapter Type! @sequel_adapter, PersistenceAdapters::Sequel end
# File lib/dynflow/coordinator_adapters/sequel.rb, line 10 def create_record(record) @sequel_adapter.insert_coordinator_record(record.to_hash) rescue ::Sequel::UniqueConstraintViolation raise Coordinator::DuplicateRecordError.new(record) end
# File lib/dynflow/coordinator_adapters/sequel.rb, line 20 def delete_record(record) @sequel_adapter.delete_coordinator_record(record.class.name, record.id) end
# File lib/dynflow/coordinator_adapters/sequel.rb, line 24 def find_records(filter_options) @sequel_adapter.find_coordinator_records(filters: filter_options) end
# File lib/dynflow/coordinator_adapters/sequel.rb, line 16 def update_record(record) @sequel_adapter.update_coordinator_record(record.class.name, record.id, record.to_hash) end