+
+
+ <%= yield(:backlink) %>
+
+ <%= yield(:page_header) %>
+
+ <%= yield %>
+
+ #{JSON.pretty_unparse(item).gsub(/\n/, '
').gsub(/\s/, ' ')}".html_safe
+ end
+
+ def failure_item_summary_list(item)
+ govuk_summary_list(html_attributes: { class: "govuk-!-font-size-16" }) do |summary_list|
+ item.each do |k, v|
+ summary_list.with_row do |row|
+ row.with_key { k }
+ row.with_value { v }
+ end
+ end
+ end
+ end
end
diff --git a/app/migration/migrators/teacher.rb b/app/migration/migrators/teacher.rb
index 56c5ec66..82de225f 100644
--- a/app/migration/migrators/teacher.rb
+++ b/app/migration/migrators/teacher.rb
@@ -9,7 +9,7 @@ def self.model
end
def self.teachers
- ::Migration::TeacherProfile.where(id: ::Migration::ParticipantProfile.ect_or_mentor.select(:teacher_profile_id).limit(100)).distinct
+ ::Migration::TeacherProfile.where(id: ::Migration::ParticipantProfile.ect_or_mentor.select(:teacher_profile_id).distinct)
end
def self.reset!
diff --git a/app/views/layouts/migration.html.erb b/app/views/layouts/migration.html.erb
new file mode 100644
index 00000000..95315123
--- /dev/null
+++ b/app/views/layouts/migration.html.erb
@@ -0,0 +1,32 @@
+
+
+ <%= render partial: "layouts/shared/head" %>
+
+
+ <%= render partial: "layouts/shared/js_enabled" %>
+
+ <%= govuk_skip_link %>
+ <%= govuk_header(full_width_border: true, html_attributes: { class: [environment_specific_header_colour_class] }) %>
+ <%= govuk_service_navigation(service_name: "Register early career teachers") do |service_navigation| %>
+ <%= service_navigation.with_navigation_item(text: "Sign out", href: sign_out_path) if authenticated? %>
+ <% end %>
+
+ <%= @migration_failures.count %> failed records
+ +<%= govuk_table do |table| + table.with_head do |head| + head.with_row do |row| + row.with_cell(text: "No.") + row.with_cell(text: "Source record") + row.with_cell(text: "Validation failure") + end + end + + table.with_body do |body| + @migration_failures.each_with_index do |failure, index| + body.with_row(html_attributes: { class: "govuk-!-font-size-16" }) do |row| + row.with_cell(text: index + 1) + row.with_cell(text: failure_item_json_code(failure.item)) + row.with_cell(text: failure.failure_message) + end + end + end +end %> diff --git a/app/views/migration/migrations/_completed_migration.html.erb b/app/views/migration/migrations/_completed_migration.html.erb index a0b3a85b..c90ea959 100644 --- a/app/views/migration/migrations/_completed_migration.html.erb +++ b/app/views/migration/migrations/_completed_migration.html.erb @@ -24,7 +24,7 @@ row.with_cell(html_attributes: { class: "total-count" }, text: data_migration_total_count_tag(data_migrations)) row.with_cell(html_attributes: { class: "failure-count" }, text: data_migration_failure_count_tag(data_migrations)) row.with_cell(html_attributes: { class: "percentage-successfully-migrated" }, text: data_migration_percentage_migrated_successfully_tag(data_migrations)) - row.with_cell(text: data_migration_download_failures_report_link(data_migrations)) + row.with_cell(text: data_migration_failures_link(data_migrations)) end end end diff --git a/config/routes.rb b/config/routes.rb index a06a91bf..086c35b1 100644 --- a/config/routes.rb +++ b/config/routes.rb @@ -44,6 +44,7 @@ scope module: "migration" do resources :migrations, only: %i[index create] do + get ":model/failures", on: :collection, to: "failures#index", as: :failures get "download_report/:model", on: :collection, action: :download_report, as: :download_report post "reset", on: :collection, action: :reset, as: :reset end diff --git a/config/solid_queue.yml b/config/solid_queue.yml index 2d8d922f..1adee37f 100644 --- a/config/solid_queue.yml +++ b/config/solid_queue.yml @@ -1,18 +1,18 @@ -# default: &default -# dispatchers: -# - polling_interval: 1 -# batch_size: 500 -# workers: -# - queues: "*" -# threads: 3 -# processes: 1 -# polling_interval: 0.1 -# -# development: -# <<: *default -# -# test: -# <<: *default -# -# production: -# <<: *default + default: &default + dispatchers: + - polling_interval: 1 + batch_size: 500 + workers: + - queues: "*" + threads: 3 + processes: 3 + polling_interval: 0.1 + + development: + <<: *default + + test: + <<: *default + + production: + <<: *default