57 lines
1.6 KiB
Ruby
57 lines
1.6 KiB
Ruby
|
# frozen_string_literal: true
|
||
|
|
|
||
|
|
class UpdateAutomationScriptModels < ActiveRecord::Migration[7.0]
|
||
|
|
def up
|
||
|
|
script_names = %w[llm_triage llm_report]
|
||
|
|
|
||
|
|
fields_to_update = DB.query(<<~SQL, script_names: script_names)
|
||
|
|
SELECT fields.id, fields.metadata
|
||
|
|
FROM discourse_automation_fields fields
|
||
|
|
INNER JOIN discourse_automation_automations automations ON automations.id = fields.automation_id
|
||
|
|
WHERE fields.name = 'model'
|
||
|
|
AND automations.script IN (:script_names)
|
||
|
|
SQL
|
||
|
|
|
||
|
|
return if fields_to_update.empty?
|
||
|
|
|
||
|
|
updated_fields =
|
||
|
|
fields_to_update
|
||
|
|
.map do |field|
|
||
|
|
new_metadata = { "value" => translate_model(field.metadata["value"]) }.to_json
|
||
|
|
|
||
|
|
"(#{field.id}, '#{new_metadata}')" if new_metadata.present?
|
||
|
|
end
|
||
|
|
.compact
|
||
|
|
|
||
|
|
return if updated_fields.empty?
|
||
|
|
|
||
|
|
DB.exec(<<~SQL)
|
||
|
|
UPDATE discourse_automation_fields AS fields
|
||
|
|
SET metadata = new_fields.metadata::jsonb
|
||
|
|
FROM (VALUES #{updated_fields.join(", ")}) AS new_fields(id, metadata)
|
||
|
|
WHERE new_fields.id::bigint = fields.id
|
||
|
|
SQL
|
||
|
|
end
|
||
|
|
|
||
|
|
def translate_model(current_model)
|
||
|
|
options = DB.query(<<~SQL, name: current_model.to_s).to_a
|
||
|
|
SELECT id, provider
|
||
|
|
FROM llm_models
|
||
|
|
WHERE name = :name
|
||
|
|
SQL
|
||
|
|
|
||
|
|
return if options.empty?
|
||
|
|
return "custom:#{options.first.id}" if options.length == 1
|
||
|
|
|
||
|
|
priority_provider = options.find { |o| o.provider == "aws_bedrock" || o.provider == "vllm" }
|
||
|
|
|
||
|
|
return "custom:#{priority_provider.id}" if priority_provider
|
||
|
|
|
||
|
|
"custom:#{options.first.id}"
|
||
|
|
end
|
||
|
|
|
||
|
|
def down
|
||
|
|
raise ActiveRecord::IrreversibleMigration
|
||
|
|
end
|
||
|
|
end
|