Contents

module Actions
  module Pulp3
    class ContentMigration < Pulp3::AbstractAsyncTask
      def plan(smart_proxy, options)
        sequence do
          action = plan_self(smart_proxy_id: smart_proxy.id)
          plan_action(Actions::Pulp3::ImportMigration, options.merge(:dependency => action.output))
        end
      end

      def invoke_external_task
        migration_service = ::Katello::Pulp3::Migration.new(smart_proxy)
        migration_service.create_and_run_migrations
      end

      def rescue_strategy
        Dynflow::Action::Rescue::Skip
      end
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
katello-3.17.3	app/lib/actions/pulp3/content_migration.rb
katello-3.17.2	app/lib/actions/pulp3/content_migration.rb
katello-3.17.1	app/lib/actions/pulp3/content_migration.rb
katello-3.18.0.rc2.1	app/lib/actions/pulp3/content_migration.rb
katello-3.18.0.rc2	app/lib/actions/pulp3/content_migration.rb
katello-3.17.0	app/lib/actions/pulp3/content_migration.rb
katello-3.18.0.rc1	app/lib/actions/pulp3/content_migration.rb
katello-3.17.0.rc2.2	app/lib/actions/pulp3/content_migration.rb
katello-3.17.0.rc2.1	app/lib/actions/pulp3/content_migration.rb
katello-3.17.0.rc2	app/lib/actions/pulp3/content_migration.rb