Merge "Use the standard messaging in the baremetal workbook"
This commit is contained in:
Zuul
Gerrit Code Review
commit
eb7d89cab1
@ -139,19 +139,13 @@ workflows:
|
|||||||
continue-on: <% task().result.provision_state != 'manageable' %>
|
continue-on: <% task().result.provision_state != 'manageable' %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.manual_cleaning
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
|
||||||
|
|
||||||
validate_nodes:
|
validate_nodes:
|
||||||
description: Validate nodes JSON
|
description: Validate nodes JSON
|
||||||
@ -179,19 +173,13 @@ workflows:
|
|||||||
message: <% task(validate_nodes).result %>
|
message: <% task(validate_nodes).result %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.validate_nodes
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
|
||||||
|
|
||||||
register_or_update:
|
register_or_update:
|
||||||
description: Take nodes JSON and create nodes in a "manageable" state
|
description: Take nodes JSON and create nodes in a "manageable" state
|
||||||
@ -282,20 +270,14 @@ workflows:
|
|||||||
message: <% task(set_nodes_available).result %>
|
message: <% task(set_nodes_available).result %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.register_or_update
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
payload: <% { registered_nodes => $.registered_nodes or [] } %>
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
registered_nodes: <% $.registered_nodes or [] %>
|
|
||||||
on-success:
|
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
|
||||||
|
|
||||||
provide:
|
provide:
|
||||||
description: Take a list of nodes and move them to "available"
|
description: Take a list of nodes and move them to "available"
|
||||||
@ -365,19 +347,13 @@ workflows:
|
|||||||
message: <% task(try_power_off).result %>
|
message: <% task(try_power_off).result %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.provide
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
|
||||||
|
|
||||||
provide_manageable_nodes:
|
provide_manageable_nodes:
|
||||||
description: Provide all nodes in a 'manageable' state.
|
description: Provide all nodes in a 'manageable' state.
|
||||||
@ -413,19 +389,13 @@ workflows:
|
|||||||
status: SUCCESS
|
status: SUCCESS
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.provide_manageable_nodes
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
|
||||||
|
|
||||||
manage:
|
manage:
|
||||||
description: Set a list of nodes to 'manageable' state
|
description: Set a list of nodes to 'manageable' state
|
||||||
@ -460,19 +430,13 @@ workflows:
|
|||||||
message: <% task(set_nodes_manageable).result %>
|
message: <% task(set_nodes_manageable).result %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.manage
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
|
||||||
|
|
||||||
_introspect:
|
_introspect:
|
||||||
description: >
|
description: >
|
||||||
@ -531,19 +495,14 @@ workflows:
|
|||||||
on-success: send_message
|
on-success: send_message
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1._introspect
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.status %>
|
payload: <% { introspected_node => $.get('introspected_node'), node_uuid => $.node_uuid } %>
|
||||||
message: <% $.message %>
|
|
||||||
introspected_node: <% $.get('introspected_node') %>
|
|
||||||
node_uuid: <% $.node_uuid %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
on-success:
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
- fail: <% $.get('status') = "FAILED" %>
|
||||||
|
|
||||||
@ -675,19 +634,14 @@ workflows:
|
|||||||
on-complete: send_message
|
on-complete: send_message
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.introspect
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
payload: <% { introspected_nodes => $.get('introspected_nodes', []), failed_introspection => $.get('failed_introspection', []) } %>
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
introspected_nodes: <% $.get('introspected_nodes', []) %>
|
|
||||||
failed_introspection: <% $.get('failed_introspection', []) %>
|
|
||||||
on-success:
|
on-success:
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
- fail: <% $.get('status') = "FAILED" %>
|
||||||
|
|
||||||
@ -746,18 +700,14 @@ workflows:
|
|||||||
introspected_nodes: []
|
introspected_nodes: []
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.introspect_manageable_nodes
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
payload: <% { introspected_nodes => $.get('introspected_nodes', []) } %>
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
introspected_nodes: <% $.get('introspected_nodes', []) %>
|
|
||||||
on-success:
|
on-success:
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
- fail: <% $.get('status') = "FAILED" %>
|
||||||
|
|
||||||
@ -807,19 +757,13 @@ workflows:
|
|||||||
message: <% task(configure_root_device).result %>
|
message: <% task(configure_root_device).result %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.configure
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
|
||||||
|
|
||||||
configure_manageable_nodes:
|
configure_manageable_nodes:
|
||||||
description: Update the boot configuration of all nodes in 'manageable' state.
|
description: Update the boot configuration of all nodes in 'manageable' state.
|
||||||
@ -874,19 +818,13 @@ workflows:
|
|||||||
message: <% task(get_manageable_nodes).result %>
|
message: <% task(get_manageable_nodes).result %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.configure_manageable_nodes
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
|
||||||
|
|
||||||
tag_node:
|
tag_node:
|
||||||
description: Tag a node with a role
|
description: Tag a node with a role
|
||||||
@ -911,19 +849,13 @@ workflows:
|
|||||||
status: SUCCESS
|
status: SUCCESS
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.tag_node
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'FAILED') %>
|
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
|
||||||
|
|
||||||
tag_nodes:
|
tag_nodes:
|
||||||
description: Runs the tag_node workflow in a loop
|
description: Runs the tag_node workflow in a loop
|
||||||
@ -969,17 +901,13 @@ workflows:
|
|||||||
status: SUCCESS
|
status: SUCCESS
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'FAILED') %>
|
||||||
type: tripleo.baremetal.v1.tag_nodes
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'FAILED') %>
|
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
on-success:
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
- fail: <% $.get('status') = "FAILED" %>
|
||||||
|
|
||||||
@ -1082,18 +1010,14 @@ workflows:
|
|||||||
message: <% task(get_matching_nodes).result %>
|
message: <% task(get_matching_nodes).result %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.nodes_with_profile
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
payload: <% { matching_nodes => $.matching_nodes or [] } %>
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
matching_nodes: <% $.matching_nodes or [] %>
|
|
||||||
on-success:
|
on-success:
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
- fail: <% $.get('status') = "FAILED" %>
|
||||||
|
|
||||||
@ -1147,19 +1071,13 @@ workflows:
|
|||||||
message: <% task(apply_configuration).result %>
|
message: <% task(apply_configuration).result %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.create_raid_configuration
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'FAILED') %>
|
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
|
||||||
|
|
||||||
|
|
||||||
cellv2_discovery:
|
cellv2_discovery:
|
||||||
@ -1198,19 +1116,13 @@ workflows:
|
|||||||
message: <% task(wait_for_nova_resources).result %>
|
message: <% task(wait_for_nova_resources).result %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.cellv2_discovery
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
on-success:
|
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
|
||||||
|
|
||||||
|
|
||||||
discover_nodes:
|
discover_nodes:
|
||||||
@ -1282,18 +1194,14 @@ workflows:
|
|||||||
message: <% task(probe_nodes).result %>
|
message: <% task(probe_nodes).result %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.discover_nodes
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
payload: <% { nodes_json => $.get('nodes_json', []) } %>
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
nodes_json: <% $.get('nodes_json', []) %>
|
|
||||||
on-success:
|
on-success:
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
- fail: <% $.get('status') = "FAILED" %>
|
||||||
|
|
||||||
@ -1353,18 +1261,14 @@ workflows:
|
|||||||
message: <% task(enroll_nodes).result %>
|
message: <% task(enroll_nodes).result %>
|
||||||
|
|
||||||
send_message:
|
send_message:
|
||||||
action: zaqar.queue_post
|
workflow: tripleo.messaging.v1.send
|
||||||
retry: count=5 delay=1
|
|
||||||
input:
|
input:
|
||||||
queue_name: <% $.queue_name %>
|
queue_name: <% $.queue_name %>
|
||||||
messages:
|
type: <% execution().name %>
|
||||||
body:
|
status: <% $.get('status', 'SUCCESS') %>
|
||||||
type: tripleo.baremetal.v1.discover_and_enroll_nodes
|
message: <% $.get('message', '') %>
|
||||||
payload:
|
execution: <% execution() %>
|
||||||
status: <% $.get('status', 'SUCCESS') %>
|
payload: <% { registered_nodes => $.get('registered_nodes', []) } %>
|
||||||
message: <% $.get('message', '') %>
|
|
||||||
execution: <% execution() %>
|
|
||||||
registered_nodes: <% $.get('registered_nodes', []) %>
|
|
||||||
on-success:
|
on-success:
|
||||||
- fail: <% $.get('status') = "FAILED" %>
|
- fail: <% $.get('status') = "FAILED" %>
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user