diff --git a/dependencies/ruby/Gemfile b/dependencies/ruby/Gemfile index a47fdac96e2..5bb99730e75 100644 --- a/dependencies/ruby/Gemfile +++ b/dependencies/ruby/Gemfile @@ -6,4 +6,4 @@ gem 'rdoc', '= 4.0.0' gem 'test-unit', '= 2.0.0.0' # OpenStudio -gem 'openstudio-aws', '~> 0.4.0.alpha2' +gem 'openstudio-aws', '~> 0.4.0.pre1' diff --git a/dependencies/ruby/Gemfile.lock b/dependencies/ruby/Gemfile.lock index ecda58e6253..8e332792672 100644 --- a/dependencies/ruby/Gemfile.lock +++ b/dependencies/ruby/Gemfile.lock @@ -12,7 +12,7 @@ GEM net-scp (1.2.1) net-ssh (>= 2.6.5) net-ssh (2.9.2) - openstudio-aws (0.4.0.alpha2) + openstudio-aws (0.4.0.pre1) aws-sdk-core (~> 2.0) net-scp (~> 1.1) semantic (~> 1.4) @@ -29,7 +29,7 @@ PLATFORMS x86-mingw32 DEPENDENCIES - openstudio-aws (~> 0.4.0.alpha2) + openstudio-aws (~> 0.4.0.pre1) rake (= 0.9.6) rdoc (= 4.0.0) test-unit (= 2.0.0.0) diff --git a/openstudiocore/ruby/cloud/aws.rb.in b/openstudiocore/ruby/cloud/aws.rb.in index 8dcc779616c..67435fd3a33 100644 --- a/openstudiocore/ruby/cloud/aws.rb.in +++ b/openstudiocore/ruby/cloud/aws.rb.in @@ -201,13 +201,8 @@ begin image_id: @server_image_id } - # Create the server & worker + # Create the server @aws.create_server server_options - worker_options = { - instance_type: @params['worker_instance_type'], - image_id: @worker_image_id - } - @aws.create_workers @params['num'], worker_options @aws.save_cluster_info 'state.json' @@ -218,7 +213,6 @@ begin unless @params.key? 'num' error(-1, 'Number of worker nodes not specified. Must be greater than or equal to 0') end -=begin worker_options = { instance_type: @params['instance_type'], image_id: @worker_image_id @@ -233,9 +227,7 @@ begin @aws.save_cluster_info 'state.json' puts @aws.cluster_info.to_json -=end - puts JSON.parse(File.read('state.json')).to_json - #@logger.info("launch_workers: #{@aws.cluster_info}") + @logger.info("launch_workers: #{@aws.cluster_info}") when 'terminate_session' @aws.load_instance_info_from_file 'state.json' @aws.terminate diff --git a/openstudiocore/src/pat_app/CloudMonitor.cpp b/openstudiocore/src/pat_app/CloudMonitor.cpp index 91328ea645a..04514b93a56 100644 --- a/openstudiocore/src/pat_app/CloudMonitor.cpp +++ b/openstudiocore/src/pat_app/CloudMonitor.cpp @@ -723,7 +723,7 @@ void StartCloudWorker::startWorking() if( provider->requestStartServer() ) { - m_error = ! provider->waitForServer(900000); + m_error = ! provider->waitForServer(); } } diff --git a/openstudiocore/src/utilities/cloud/AWSProvider.cpp b/openstudiocore/src/utilities/cloud/AWSProvider.cpp index 7de294ce22c..c5028038c27 100644 --- a/openstudiocore/src/utilities/cloud/AWSProvider.cpp +++ b/openstudiocore/src/utilities/cloud/AWSProvider.cpp @@ -1523,8 +1523,6 @@ namespace openstudio{ QJsonObject options; options["instance_type"] = QJsonValue(toQString(m_awsSettings.serverInstanceType())); - options["worker_instance_type"] = QJsonValue(toQString(m_awsSettings.workerInstanceType())); - options["num"] = QJsonValue(static_cast(m_awsSettings.numWorkers())); options["openstudio_version"] = QJsonValue(toQString(openStudioVersion())); args << QString(QJsonDocument(options).toJson(QJsonDocument::Compact)); @@ -2079,6 +2077,7 @@ namespace openstudio{ auto jsonObject = json.object(); auto serverObject = jsonObject["server"].toObject(); serverObject["private_key_file_name"] = m_workingDir.path() + "/ec2_server_key.pem"; + serverObject["worker_private_key_file_name"] = m_workingDir.path() + "/ec2_worker_key.pem"; jsonObject["server"] = serverObject; auto workers = jsonObject["workers"].toArray(); for (auto i = 0; i < workers.size(); ++i) {