Sha256: 99d20da4b2eeedcaf490a6fa5e8cbff295c8d6614ea1c7a8cc56f5b304fd87c9
Contents?: true
Size: 1.91 KB
Versions: 44
Compression:
Stored size: 1.91 KB
Contents
plan canary(
Optional[String[0]] $task = undef,
Optional[String[0]] $command = undef,
Optional[String[0]] $script = undef,
TargetSpec $nodes,
Hash[String, Data] $params = {},
Integer $canary_size = 1
) {
# Validation
$type_count = [$task, $command, $script].reduce(0) |$acc, $v| {
if ($v) {
$acc + 1
} else {
$acc
}
}
if ($type_count == 0) {
fail_plan("Must specify a command, script, or task to run", 'canary/invalid-params')
}
if ($type_count > 1) {
fail_plan("Must specify only one command, script, or task to run", 'canary/invalid-params')
}
[$canaries, $rest] = canary::random_split(get_targets($nodes), $canary_size)
$catch_params = $params + { '_catch_errors' => true }
if ($task) {
$action = 'run_task'
$object = $task
$canr = run_task($task, $canaries, $catch_params)
if ($canr.ok) {
$restr = run_task($task, $rest, $catch_params)
}
} elsif ($command) {
$action = 'run_command'
$object = $command
$canr = run_command($command, $canaries, $catch_params)
if ($canr.ok) {
$restr = run_command($command, $rest, $catch_params)
}
} elsif ($script) {
$action = 'run_script'
$object = $script
$canr = run_script($script, $canaries, $catch_params)
if ($canr.ok) {
$restr = run_script($script, $rest, $catch_params)
}
}
unless ($canr.ok) {
$restr = canary::skip($rest)
}
$merged_result = canary::merge($canr, $restr)
unless ($merged_result.ok) {
if ($canr.ok) {
$message = "Plan failed for ${merged_result.error_set.count} targets."
}
else {
$message = "Plan aborted. ${canr.error_set.count} canary target failures. ${restr.count} targets skipped."
}
$details = {'action' => $action,
'object' => $object,
'result_set' => $merged_result}
fail_plan($message, 'bolt/run-failure', $details)
}
return $merged_result
}
Version data entries
44 entries across 44 versions & 1 rubygems