cookbooks/aws-parallelcluster-slurm/spec/unit/recipes/update_head_node_spec.rb (58 lines of code) (raw):

require 'spec_helper' describe 'aws-parallelcluster-slurm::update_head_node' do for_all_oses do |platform, version| cookbook_venv_path = "MOCK_COOKBOOK_VENV_PATH" cluster_name = "MOCK_CLUSTER_NAME" region = "MOCK_REGION" cluster_config_version = "MOCK_CLUSTER_CONFIG_VERSION" scripts_dir = "/MOCK_SCRIPTS_DIR" context "on #{platform}#{version}" do [true, false].each do |are_mount_or_unmount_required| context "when mount/unmount is #{'not ' unless are_mount_or_unmount_required}required" do cached(:chef_run) do runner = runner(platform: platform, version: version) do |node| allow_any_instance_of(Object).to receive(:are_mount_or_unmount_required?).and_return(are_mount_or_unmount_required) allow_any_instance_of(Object).to receive(:dig).and_return(true) allow_any_instance_of(Object).to receive(:cookbook_virtualenv_path).and_return(cookbook_venv_path) RSpec::Mocks.configuration.allow_message_expectations_on_nil = true node.override['cluster']['stack_name'] = cluster_name node.override['cluster']['region'] = region node.override['cluster']['cluster_config_version'] = cluster_config_version node.override['cluster']['scripts_dir'] = scripts_dir end runner.converge(described_recipe) end it 'creates the template cfnconfig' do is_expected.to create_template('/etc/parallelcluster/cfnconfig').with( source: 'init/cfnconfig.erb', cookbook: 'aws-parallelcluster-environment', mode: '0644' ) end if are_mount_or_unmount_required it 'updates the shared storage' do is_expected.to run_ruby_block("update_shared_storages") end else it 'does not update the shared storage' do is_expected.not_to run_ruby_block("update_shared_storages") end end it 'checks cluster readiness' do expected_command = "#{cookbook_venv_path}/bin/python #{scripts_dir}/head_node_checks/check_cluster_ready.py" \ " --cluster-name #{cluster_name}" \ " --table-name parallelcluster-#{cluster_name}" \ " --config-version #{cluster_config_version}" \ " --region #{region}" is_expected.to run_execute("Check cluster readiness").with( command: expected_command, timeout: 30, retries: 10, retry_delay: 90 ) end end end end end end