Merge "Fetch noop_run option from deployment_options"
This commit is contained in:
commit
31f763227f
|
@ -92,7 +92,8 @@ module Astute
|
||||||
:tasks_graph => data['args'].fetch('tasks_graph', {}),
|
:tasks_graph => data['args'].fetch('tasks_graph', {}),
|
||||||
:tasks_directory => data['args'].fetch('tasks_directory', {}),
|
:tasks_directory => data['args'].fetch('tasks_directory', {}),
|
||||||
:tasks_metadata => data['args'].fetch('tasks_metadata', {}),
|
:tasks_metadata => data['args'].fetch('tasks_metadata', {}),
|
||||||
:dry_run => data['args'].fetch('dry_run', false)
|
:dry_run => data['args'].fetch('dry_run', false),
|
||||||
|
:noop_run => data['args'].fetch('noop_run', false)
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
rescue Timeout::Error
|
rescue Timeout::Error
|
||||||
|
|
|
@ -48,10 +48,7 @@ module Astute
|
||||||
'fault_tolerance_groups',
|
'fault_tolerance_groups',
|
||||||
[]
|
[]
|
||||||
)
|
)
|
||||||
cluster.noop_run = tasks_metadata.fetch(
|
cluster.noop_run = deployment_options.fetch(:noop_run, false)
|
||||||
'noop_run',
|
|
||||||
false
|
|
||||||
)
|
|
||||||
|
|
||||||
cluster.node_statuses_transitions = tasks_metadata.fetch(
|
cluster.node_statuses_transitions = tasks_metadata.fetch(
|
||||||
'node_statuses_transitions',
|
'node_statuses_transitions',
|
||||||
|
|
|
@ -305,9 +305,10 @@ describe Astute::TaskDeployment do
|
||||||
|
|
||||||
Astute::TaskCluster.any_instance.expects(:run).returns({:success => true})
|
Astute::TaskCluster.any_instance.expects(:run).returns({:success => true})
|
||||||
task_deployment.deploy(
|
task_deployment.deploy(
|
||||||
tasks_metadata: tasks_metadata.merge({'noop_run' => true}),
|
tasks_metadata: tasks_metadata,
|
||||||
tasks_graph: tasks_graph,
|
tasks_graph: tasks_graph,
|
||||||
tasks_directory: tasks_directory)
|
tasks_directory: tasks_directory,
|
||||||
|
noop_run: true)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue