[Bug] "Target substrate not found" in command "calm decompile bp"

[nx-sbourdeaud]

Describe the bug
When decompiling a multi-vm blueprint from an NCM 4.2.0 instance using NCM DSL 4.1.1, getting a "Target substrate not found" error (blueprint works fine in NCM).

Branch/Container
Branch or Container where it is happening: master 4.1.1

To Reproduce
Steps to reproduce the behavior:

1. Import attached json blueprint
2. run calm decompile on this bp
3. See error

Expected behavior
Working blueprint should decompile fine.

Findings/Troubleshooting Done
n/a

Available Logs/Data

#calm decompile bp vendure                                                                                                                                                                                                                                                                                       
[2025-07-17 06:27:36] [INFO] [calm.dsl.cli.bps:831] vendure found 
[2025-07-17 06:27:39] [INFO] [calm.dsl.cli.bps:728] Decompiling blueprint vendure
[2025-07-17 06:27:39] [WARNING] [calm.dsl.builtins.models.object_type:90] Additional Property (upgrade_runbook) found
[2025-07-17 06:27:39] [WARNING] [calm.dsl.builtins.models.object_type:90] Additional Property (upgrade_runbook) found
[2025-07-17 06:27:39] [WARNING] [calm.dsl.builtins.models.object_type:90] Additional Property (upgrade_runbook) found
[2025-07-17 06:27:39] [INFO] [calm.dsl.decompile.decompile_render:70] Creating blueprint directory
[2025-07-17 06:27:39] [INFO] [calm.dsl.decompile.decompile_render:72] Rendering blueprint file template
Traceback (most recent call last):
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/venv/bin/calm", line 33, in <module>
    sys.exit(load_entry_point('calm.dsl', 'console_scripts', 'calm')())
             ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/venv/lib/python3.13/site-packages/click/core.py", line 1128, in __call__
    return self.main(*args, **kwargs)
           ~~~~~~~~~^^^^^^^^^^^^^^^^^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/venv/lib/python3.13/site-packages/click/core.py", line 1053, in main
    rv = self.invoke(ctx)
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/cli/utils.py", line 147, in invoke
    return super().invoke(ctx)
           ~~~~~~~~~~~~~~^^^^^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/venv/lib/python3.13/site-packages/click/core.py", line 1659, in invoke
    return _process_result(sub_ctx.command.invoke(sub_ctx))
                           ~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/cli/utils.py", line 147, in invoke
    return super().invoke(ctx)
           ~~~~~~~~~~~~~~^^^^^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/venv/lib/python3.13/site-packages/click/core.py", line 1659, in invoke
    return _process_result(sub_ctx.command.invoke(sub_ctx))
                           ~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/venv/lib/python3.13/site-packages/click/core.py", line 1395, in invoke
    return ctx.invoke(self.callback, **ctx.params)
           ~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/venv/lib/python3.13/site-packages/click/core.py", line 754, in invoke
    return __callback(*args, **kwargs)
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/cli/bp_commands.py", line 168, in _decompile_bp
    decompile_bp(name, bp_file, with_secrets, prefix, bp_dir, passphrase, no_format)
    ~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/cli/bps.py", line 563, in decompile_bp
    decompile_bp_from_server(
    ~~~~~~~~~~~~~~~~~~~~~~~~^
        name=name,
        ^^^^^^^^^^
    ...<3 lines>...
        no_format=no_format,
        ^^^^^^^^^^^^^^^^^^^^
    )
    ^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/cli/bps.py", line 615, in decompile_bp_from_server
    _decompile_bp(
    ~~~~~~~~~~~~~^
        bp_payload=exported_bp_res_payload,
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    ...<4 lines>...
        **kwargs,
        ^^^^^^^^^
    )
    ^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/cli/bps.py", line 747, in _decompile_bp
    create_bp_dir(
    ~~~~~~~~~~~~~^
        bp_cls=bp_cls,
        ^^^^^^^^^^^^^^
    ...<4 lines>...
        no_format=no_format,
        ^^^^^^^^^^^^^^^^^^^^
    )
    ^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/decompile/decompile_render.py", line 73, in create_bp_dir
    bp_data = render_bp_file_template(
        cls=bp_cls,
    ...<2 lines>...
        contains_encrypted_secrets=contains_encrypted_secrets,
    )
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/decompile/bp_file_helper.py", line 212, in render_bp_file_template
    dependepent_entities[k] = render_package_template(
                              ~~~~~~~~~~~~~~~~~~~~~~~^
        v, secrets_dict, endpoints=endpoints, ep_list=ep_list
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    )
    ^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/decompile/package.py", line 51, in render_package_template
    render_action_template(
    ~~~~~~~~~~~~~~~~~~~~~~^
        cls.__install__,
        ^^^^^^^^^^^^^^^^
    ...<4 lines>...
        ep_list=ep_list,
        ^^^^^^^^^^^^^^^^
    )
    ^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/decompile/action.py", line 59, in render_action_template
    render_task_tree_template(
    ~~~~~~~~~~~~~~~~~~~~~~~~~^
        root_node,
        ^^^^^^^^^^
    ...<9 lines>...
        rendered_credential_list=rendered_credential_list,
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    )
    ^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/decompile/task_tree.py", line 90, in render_task_tree_template
    rendered_tasks[task.get("task_name")] = render_task_template(
                                            ~~~~~~~~~~~~~~~~~~~~^
        task.get("task_data"),
        ^^^^^^^^^^^^^^^^^^^^^^
    ...<6 lines>...
        rendered_credential_list=rendered_credential_list,
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    )
    ^
  File "/Users/stephan.bourdea/Documents/github/solutions-hc-lab/ncm/mid-market/calm-dsl/calm/dsl/decompile/task.py", line 242, in render_task_template
    raise ValueError("Target substrate not found")
ValueError: Target substrate not found

#calm --version       
calm, version 4.1.1

** System Configuration:**

• OS: Mac OSX Sequoia 15.5
• Python: 3.13.3

Additional context
n/a

[nx-sbourdeaud]

{"status":{},"spec":{"name":"vendure","description":"","resources":{"service_definition_list":[{"name":"vendure_db","description":"","variable_list":[],"action_list":[{"type":"system","name":"action_create","description":"System action for creating an application","runbook":{"name":"b58cef57_runbook","description":"","task_definition_list":[{"type":"DAG","name":"71ac1c10_dag","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"71ac1c10_dag","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_delete","description":"System action for deleting an application. Deletes created VMs as well","runbook":{"name":"9e862109_runbook","description":"","task_definition_list":[{"type":"DAG","name":"8916d0dc_dag","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"8916d0dc_dag","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_start","description":"System action for starting an application","runbook":{"name":"dff54fce_runbook","description":"","task_definition_list":[{"type":"DAG","name":"364f5584_dag","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[{"name":"StartPg","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"StartPg","description":"","attrs":{"type":"","script":"echo \"wip\"\n#systemctl start container-pg.service","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"364f5584_dag","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_stop","description":"System action for stopping an application","runbook":{"name":"896b0cdb_runbook","description":"","task_definition_list":[{"type":"DAG","name":"bee7ed1b_dag","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[{"name":"StopPg","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"StopPg","description":"","attrs":{"type":"","script":"systemctl stop container-pg.service","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"bee7ed1b_dag","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_restart","description":"System action for restarting an application","runbook":{"name":"aed5694f_runbook","description":"","task_definition_list":[{"type":"DAG","name":"47328c7c_dag","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"47328c7c_dag","kind":"app_task"},"variable_list":[]},"critical":false}],"depends_on_list":[],"port_list":[],"singleton":false,"tier":""},{"name":"vendure_app","description":"","variable_list":[],"action_list":[{"type":"system","name":"action_create","description":"System action for creating an application","runbook":{"name":"b58cef57_runbook_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"71ac1c10_dag_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"71ac1c10_dag_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_delete","description":"System action for deleting an application. Deletes created VMs as well","runbook":{"name":"9e862109_runbook_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"8916d0dc_dag_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"8916d0dc_dag_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_start","description":"System action for starting an application","runbook":{"name":"dff54fce_runbook_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"364f5584_dag_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[{"name":"StartVendure","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"StartVendure","description":"","attrs":{"type":"","script":"cd @@{APP_DATA_DISK_MOUNTPOINT}@@\ncd my-shop\npm2 start npm -- start","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"364f5584_dag_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_stop","description":"System action for stopping an application","runbook":{"name":"896b0cdb_runbook_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"bee7ed1b_dag_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[{"name":"StopVendure","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"StopVendure","description":"","attrs":{"type":"","script":"cd @@{APP_DATA_DISK_MOUNTPOINT}@@\ncd my-shop\npm2 stop npm","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"bee7ed1b_dag_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_restart","description":"System action for restarting an application","runbook":{"name":"aed5694f_runbook_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"47328c7c_dag_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"47328c7c_dag_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false}],"depends_on_list":[],"port_list":[],"singleton":false,"tier":""},{"name":"vendure_web","description":"","variable_list":[],"action_list":[{"type":"system","name":"action_create","description":"System action for creating an application","runbook":{"name":"b58cef57_runbook_cloned_0_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"71ac1c10_dag_cloned_1_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"71ac1c10_dag_cloned_1_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_delete","description":"System action for deleting an application. Deletes created VMs as well","runbook":{"name":"9e862109_runbook_cloned_0_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"8916d0dc_dag_cloned_1_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"8916d0dc_dag_cloned_1_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_start","description":"System action for starting an application","runbook":{"name":"dff54fce_runbook_cloned_0_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"364f5584_dag_cloned_1_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"364f5584_dag_cloned_1_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_stop","description":"System action for stopping an application","runbook":{"name":"896b0cdb_runbook_cloned_0_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"bee7ed1b_dag_cloned_1_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"bee7ed1b_dag_cloned_1_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"system","name":"action_restart","description":"System action for restarting an application","runbook":{"name":"aed5694f_runbook_cloned_0_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"47328c7c_dag_cloned_1_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"47328c7c_dag_cloned_1_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false}],"depends_on_list":[],"port_list":[],"singleton":false,"tier":""}],"published_service_definition_list":[],"substrate_definition_list":[{"type":"AHV_VM","name":"db_backend","description":"","variable_list":[],"action_list":[{"type":"fragment","name":"pre_action_create","description":"","runbook":{"name":"ae5af197_runbook","description":"","task_definition_list":[{"type":"DAG","name":"b74fd873_dag","description":"","attrs":{"type":"","edges":[{"type":"","from_task_reference":{"name":"SetPcApiUrl","kind":"app_task"},"to_task_reference":{"name":"DefineCategoryValue","kind":"app_task"},"edge_type":"user_defined"}]},"child_tasks_local_reference_list":[{"name":"DefineCategoryValue","kind":"app_task"},{"name":"SetPcApiUrl","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"db_backend","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"SET_VARIABLE","name":"DefineCategoryValue","description":"","attrs":{"type":"","script":"env_name = \"@@{calm_environment_name}@@\"\nsla = \"@@{SLA}@@\"\n\nif sla == \"Gold\":\n\tcategory_value = \"RPOZero\"\nelif sla == \"Silver\":\n    category_value = \"RPO15m\"\nelif sla == \"Bronze\":\n    category_value = \"RPO2h\"\nelif sla == \"None\":\n    print('INFO: Replication set to None - skipping Category definition')\n    exit(0)\nelse:\n    print(f'ERROR: Expecting Gold\/Silver\/Bronze as value, but received {sla}')\n    exit(1)\n\ncategory_name = f\"{env_name}-DR-{sla}-01\"\nprint(f\"CATEGORY_NAME={category_name}\")\nprint(f\"CATEGORY_VALUE={category_value}\")\nexit(0)","script_type":"static_py3","exit_status":[],"eval_scope":"local","eval_variables":["CATEGORY_NAME","CATEGORY_VALUE"]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"db_backend","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"SET_VARIABLE","name":"SetPcApiUrl","description":"","attrs":{"type":"","script":"env_name = \"@@{calm_environment_name}@@\"\naz01_pc = \"az01pc01.nvd.local\"\naz02_pc = \"az02pc01.nvd.local\"\n\nif env_name.lower().startswith(\"az01\"):\n    print(\"PC_API_FQDN={}\".format(az01_pc))\n    exit(0)\nelif env_name.lower().startswith(\"az02\"):\n    print(\"PC_API_FQDN={}\".format(az02_pc))\n    exit(0)\nelse:\n    print(\"ERROR: Unable to retrieve Prism Central details - exiting...\")\n    exit(1)","script_type":"static_py3","exit_status":[],"eval_scope":"local","eval_variables":["PC_API_FQDN"]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"db_backend","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"b74fd873_dag","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"fragment","name":"post_action_create","description":"","runbook":{"name":"440af2bc_runbook","description":"","task_definition_list":[{"type":"DAG","name":"6b1041b3_dag","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[{"name":"AssignCategories","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"db_backend","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"AssignCategories","description":"","attrs":{"type":"","script":"import requests\nfrom requests.auth import HTTPBasicAuth\n\n# Initialize variables\napi_fqdn = '@@{PC_API_FQDN}@@'\napi_user = '@@{prism_central.username}@@'\napi_pass = '@@{prism_central.secret}@@'\n\n# Load VM details\nvm_details = json.loads('''@@{platform}@@''')\nvm_uuid = vm_details['metadata']['uuid']\nif '@@{SLA}@@' != 'None':\n    vm_details['metadata']['categories']['@@{CATEGORY_NAME}@@'] = '@@{CATEGORY_VALUE}@@'\nvm_details['metadata']['categories']['AppTier'] = 'SSH'\ndel vm_details['status']\n\n# Prepare payload and headers\npayload = vm_details\nheaders = {'Content-Type': 'application\/json', 'Accept': 'application\/json'}\nurl = 'https:\/\/{}:9440\/api\/nutanix\/v3\/vms\/{}'.format(api_fqdn, vm_uuid)\n\n# Make the request\nresp = requests.put(url, auth=HTTPBasicAuth(api_user, api_pass), json=payload, headers=headers, verify=False)\n\n# Check the response\nif resp.ok:\n    result = resp.json()\n    if '@@{SLA}@@' != 'None':\n        print('SUCCESS: Assigned VM {} to category {}:{}'.format(vm_details['spec']['name'], '@@{CATEGORY_NAME}@@', '@@{CATEGORY_VALUE}@@'))\n    print('SUCCESS: Assigned VM {} to category AppTier:{}'.format(vm_details['spec']['name'], 'SSH'))    \n    exit(0)\nelse:\n    print(resp)\n    print('ERROR: Unable to assign VM to category')\n    exit(1)","script_type":"static_py3","command_line_args":"","exit_status":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"db_backend","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"6b1041b3_dag","kind":"app_task"},"variable_list":[]},"critical":false}],"editables":{"create_spec":{"resources":{"disk_list":{"0":{},"1":{}},"boot_config":{"boot_type":false,"boot_device":true},"vtpm_config":{"vtpm_enabled":false}}}},"create_spec":{"type":"","name":"vendure-db","availability_zone_reference":null,"backup_policy":null,"cluster_reference":{"type":"","kind":"cluster","name":"az01app01","uuid":"000630cb-92a6-a024-7d1c-58a2e10e3810"},"resources":{"type":"","nic_list":[{"type":"","nic_type":"NORMAL_NIC","subnet_reference":{"type":"","kind":"subnet","name":"","uuid":"341d53fe-615f-4243-9b74-208d9bc08e04"},"network_function_nic_type":"INGRESS","mac_address":"","ip_endpoint_list":[],"network_function_chain_reference":null,"vpc_reference":{"type":"","kind":"vpc","name":"","uuid":"66d7fa14-da3f-4a98-99ba-2da8608aaf02"}}],"power_state":"ON","guest_tools":null,"num_vcpus_per_socket":1,"num_sockets":4,"memory_size_mib":16384,"gpu_list":[],"parent_reference":null,"hardware_clock_timezone":"","account_uuid":"0f045529-e3cf-4d77-acd2-92413d341ccc","guest_customization":{"type":"","cloud_init":{"type":"","meta_data":"","user_data":"#cloud-config\ntimezone: UTC\ndisable_root: False\nssh_pwauth: True\nhostname: @@{name}@@\nfqdn: @@{name}@@.@@{DOMAIN}@@\n\nusers:\n  - name: @@{cred_linux.username}@@\n    lock_passwd: false\n    sudo: ['ALL=(ALL) NOPASSWD:ALL']\n    ssh-authorized-keys:\n      - @@{OS_CRED_PUBLIC_KEY}@@\n\nchpasswd:\n   list: |\n     @@{cred_linux.username}@@:Nutanix.123\n   expire: false\n\ngrowpart:\n  mode: auto\n  devices: ['\/']\n  ignore_growroot_disabled: false\n\npackage_upgrade: false\n"},"sysprep":null},"boot_config":{"type":"","boot_device":{"type":"","disk_address":{"type":"","device_index":0,"adapter_type":"SCSI"}},"mac_address":"","boot_type":"UEFI"},"vtpm_config":null,"disk_list":[{"type":"","data_source_reference":{"type":"","kind":"app_package","name":"RHEL9","uuid":"e49871d4-e16a-4849-91f6-c03c3dc492d4"},"volume_group_reference":null,"device_properties":{"type":"","disk_address":{"type":"","device_index":0,"adapter_type":"SCSI"},"device_type":"DISK"},"disk_size_mib":102400},{"type":"","data_source_reference":null,"volume_group_reference":null,"device_properties":{"type":"","disk_address":{"type":"","device_index":1,"adapter_type":"SCSI"},"device_type":"DISK"},"disk_size_mib":512000}],"serial_port_list":[]},"categories":{}},"os_type":"Linux","readiness_probe":{"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"},"connection_type":"SSH","connection_port":22,"delay_secs":"30","retries":"5","address":"@@{platform.status.resources.nic_list[0].ip_endpoint_list[0].ip}@@","disable_readiness_probe":false,"connection_protocol":""}},{"type":"AHV_VM","name":"web_app","description":"","variable_list":[],"action_list":[{"type":"fragment","name":"pre_action_create","description":"","runbook":{"name":"ae5af197_runbook_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"b74fd873_dag_cloned_1","description":"","attrs":{"type":"","edges":[{"type":"","from_task_reference":{"name":"SetPcApiUrl1","kind":"app_task"},"to_task_reference":{"name":"DefineCategoryValue1","kind":"app_task"},"edge_type":"user_defined"}]},"child_tasks_local_reference_list":[{"name":"DefineCategoryValue1","kind":"app_task"},{"name":"SetPcApiUrl1","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"web_app","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"SET_VARIABLE","name":"DefineCategoryValue1","description":"","attrs":{"type":"","script":"env_name = \"@@{calm_environment_name}@@\"\nsla = \"@@{SLA}@@\"\n\nif sla == \"Gold\":\n\tcategory_value = \"RPOZero\"\nelif sla == \"Silver\":\n    category_value = \"RPO15m\"\nelif sla == \"Bronze\":\n    category_value = \"RPO2h\"\nelif sla == \"None\":\n    print('INFO: Replication set to None - skipping Category definition')\n    exit(0)\nelse:\n    print(f'ERROR: Expecting Gold\/Silver\/Bronze as value, but received {sla}')\n    exit(1)\n\ncategory_name = f\"{env_name}-DR-{sla}-01\"\nprint(f\"CATEGORY_NAME={category_name}\")\nprint(f\"CATEGORY_VALUE={category_value}\")\nexit(0)","script_type":"static_py3","exit_status":[],"eval_scope":"local","eval_variables":["CATEGORY_NAME","CATEGORY_VALUE"]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"web_app","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"SET_VARIABLE","name":"SetPcApiUrl1","description":"","attrs":{"type":"","script":"env_name = \"@@{calm_environment_name}@@\"\naz01_pc = \"az01pc01.nvd.local\"\naz02_pc = \"az02pc01.nvd.local\"\n\nif env_name.lower().startswith(\"az01\"):\n    print(\"PC_API_FQDN={}\".format(az01_pc))\n    exit(0)\nelif env_name.lower().startswith(\"az02\"):\n    print(\"PC_API_FQDN={}\".format(az02_pc))\n    exit(0)\nelse:\n    print(\"ERROR: Unable to retrieve Prism Central details - exiting...\")\n    exit(1)","script_type":"static_py3","exit_status":[],"eval_scope":"local","eval_variables":["PC_API_FQDN"]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"web_app","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"b74fd873_dag_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"fragment","name":"post_action_create","description":"","runbook":{"name":"440af2bc_runbook_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"6b1041b3_dag_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[{"name":"AssignCategories1","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"web_app","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"AssignCategories1","description":"","attrs":{"type":"","script":"import requests\nfrom requests.auth import HTTPBasicAuth\n\n# Initialize variables\napi_fqdn = '@@{PC_API_FQDN}@@'\napi_user = '@@{prism_central.username}@@'\napi_pass = '@@{prism_central.secret}@@'\n\n# Load VM details\nvm_details = json.loads('''@@{platform}@@''')\nvm_uuid = vm_details['metadata']['uuid']\nif '@@{SLA}@@' != 'None':\n    vm_details['metadata']['categories']['@@{CATEGORY_NAME}@@'] = '@@{CATEGORY_VALUE}@@'\nvm_details['metadata']['categories']['AppTier'] = 'SSH'\ndel vm_details['status']\n\n# Prepare payload and headers\npayload = vm_details\nheaders = {'Content-Type': 'application\/json', 'Accept': 'application\/json'}\nurl = 'https:\/\/{}:9440\/api\/nutanix\/v3\/vms\/{}'.format(api_fqdn, vm_uuid)\n\n# Make the request\nresp = requests.put(url, auth=HTTPBasicAuth(api_user, api_pass), json=payload, headers=headers, verify=False)\n\n# Check the response\nif resp.ok:\n    result = resp.json()\n    if '@@{SLA}@@' != 'None':\n        print('SUCCESS: Assigned VM {} to category {}:{}'.format(vm_details['spec']['name'], '@@{CATEGORY_NAME}@@', '@@{CATEGORY_VALUE}@@'))\n    print('SUCCESS: Assigned VM {} to category AppTier:{}'.format(vm_details['spec']['name'], 'SSH'))    \n    exit(0)\nelse:\n    print(resp)\n    print('ERROR: Unable to assign VM to category')\n    exit(1)","script_type":"static_py3","command_line_args":"","exit_status":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"web_app","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"6b1041b3_dag_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"fragment","name":"post_action_delete","description":"","runbook":{"name":"22b7e2d9_runbook","description":"","task_definition_list":[{"type":"DAG","name":"a8026222_dag","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"web_app","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"a8026222_dag","kind":"app_task"},"variable_list":[]},"critical":false}],"editables":{"create_spec":{"resources":{"disk_list":{"0":{},"1":{}},"boot_config":{"boot_type":false,"boot_device":true},"vtpm_config":{"vtpm_enabled":false}}}},"create_spec":{"type":"","name":"vendure-app","availability_zone_reference":null,"backup_policy":null,"cluster_reference":{"type":"","kind":"cluster","name":"az01app01","uuid":"000630cb-92a6-a024-7d1c-58a2e10e3810"},"resources":{"type":"","nic_list":[{"type":"","nic_type":"NORMAL_NIC","subnet_reference":{"type":"","kind":"subnet","name":"","uuid":"341d53fe-615f-4243-9b74-208d9bc08e04"},"network_function_nic_type":"INGRESS","mac_address":"","ip_endpoint_list":[],"network_function_chain_reference":null,"vpc_reference":{"type":"","kind":"vpc","name":"","uuid":"66d7fa14-da3f-4a98-99ba-2da8608aaf02"}}],"power_state":"ON","guest_tools":null,"num_vcpus_per_socket":1,"num_sockets":4,"memory_size_mib":16384,"gpu_list":[],"parent_reference":null,"hardware_clock_timezone":"","account_uuid":"0f045529-e3cf-4d77-acd2-92413d341ccc","guest_customization":{"type":"","cloud_init":{"type":"","meta_data":"","user_data":"#cloud-config\ntimezone: UTC\ndisable_root: False\nssh_pwauth: True\nhostname: @@{name}@@\nfqdn: @@{name}@@.@@{DOMAIN}@@\n\nusers:\n  - name: @@{cred_linux.username}@@\n    lock_passwd: false\n    sudo: ['ALL=(ALL) NOPASSWD:ALL']\n    ssh-authorized-keys:\n      - @@{OS_CRED_PUBLIC_KEY}@@\n\nchpasswd:\n   list: |\n     @@{cred_linux.username}@@:Nutanix.123\n   expire: false\n\ngrowpart:\n  mode: auto\n  devices: ['\/']\n  ignore_growroot_disabled: false\n\npackage_upgrade: false\n"},"sysprep":null},"boot_config":{"type":"","boot_device":{"type":"","disk_address":{"type":"","device_index":0,"adapter_type":"SCSI"}},"mac_address":"","boot_type":"UEFI"},"vtpm_config":null,"disk_list":[{"type":"","data_source_reference":{"type":"","kind":"app_package","name":"RHEL9","uuid":"e49871d4-e16a-4849-91f6-c03c3dc492d4"},"volume_group_reference":null,"device_properties":{"type":"","disk_address":{"type":"","device_index":0,"adapter_type":"SCSI"},"device_type":"DISK"},"disk_size_mib":102400},{"type":"","data_source_reference":null,"volume_group_reference":null,"device_properties":{"type":"","disk_address":{"type":"","device_index":1,"adapter_type":"SCSI"},"device_type":"DISK"},"disk_size_mib":512000}],"serial_port_list":[]},"categories":{}},"os_type":"Linux","readiness_probe":{"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"},"connection_type":"SSH","connection_port":22,"delay_secs":"30","retries":"5","address":"@@{platform.status.resources.nic_list[0].ip_endpoint_list[0].ip}@@","disable_readiness_probe":false,"connection_protocol":""}},{"type":"AHV_VM","name":"web_frontend","description":"","variable_list":[],"action_list":[{"type":"fragment","name":"pre_action_create","description":"","runbook":{"name":"ae5af197_runbook_cloned_0_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"b74fd873_dag_cloned_1_cloned_1","description":"","attrs":{"type":"","edges":[{"type":"","from_task_reference":{"name":"SetPcApiUrl2","kind":"app_task"},"to_task_reference":{"name":"DefineCategoryValue2","kind":"app_task"},"edge_type":"user_defined"}]},"child_tasks_local_reference_list":[{"name":"DefineCategoryValue2","kind":"app_task"},{"name":"SetPcApiUrl2","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"web_frontend","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"SET_VARIABLE","name":"DefineCategoryValue2","description":"","attrs":{"type":"","script":"env_name = \"@@{calm_environment_name}@@\"\nsla = \"@@{SLA}@@\"\n\nif sla == \"Gold\":\n\tcategory_value = \"RPOZero\"\nelif sla == \"Silver\":\n    category_value = \"RPO15m\"\nelif sla == \"Bronze\":\n    category_value = \"RPO2h\"\nelif sla == \"None\":\n    print('INFO: Replication set to None - skipping Category definition')\n    exit(0)\nelse:\n    print(f'ERROR: Expecting Gold\/Silver\/Bronze as value, but received {sla}')\n    exit(1)\n\ncategory_name = f\"{env_name}-DR-{sla}-01\"\nprint(f\"CATEGORY_NAME={category_name}\")\nprint(f\"CATEGORY_VALUE={category_value}\")\nexit(0)","script_type":"static_py3","exit_status":[],"eval_scope":"local","eval_variables":["CATEGORY_NAME","CATEGORY_VALUE"]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"web_frontend","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"SET_VARIABLE","name":"SetPcApiUrl2","description":"","attrs":{"type":"","script":"env_name = \"@@{calm_environment_name}@@\"\naz01_pc = \"az01pc01.nvd.local\"\naz02_pc = \"az02pc01.nvd.local\"\n\nif env_name.lower().startswith(\"az01\"):\n    print(\"PC_API_FQDN={}\".format(az01_pc))\n    exit(0)\nelif env_name.lower().startswith(\"az02\"):\n    print(\"PC_API_FQDN={}\".format(az02_pc))\n    exit(0)\nelse:\n    print(\"ERROR: Unable to retrieve Prism Central details - exiting...\")\n    exit(1)","script_type":"static_py3","exit_status":[],"eval_scope":"local","eval_variables":["PC_API_FQDN"]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"web_frontend","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"b74fd873_dag_cloned_1_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"fragment","name":"post_action_create","description":"","runbook":{"name":"440af2bc_runbook_cloned_0_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"6b1041b3_dag_cloned_1_cloned_1","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[{"name":"AssignCategories2","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"web_frontend","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"AssignCategories2","description":"","attrs":{"type":"","script":"import requests\nfrom requests.auth import HTTPBasicAuth\n\n# Initialize variables\napi_fqdn = '@@{PC_API_FQDN}@@'\napi_user = '@@{prism_central.username}@@'\napi_pass = '@@{prism_central.secret}@@'\n\n# Load VM details\nvm_details = json.loads('''@@{platform}@@''')\nvm_uuid = vm_details['metadata']['uuid']\nif '@@{SLA}@@' != 'None':\n    vm_details['metadata']['categories']['@@{CATEGORY_NAME}@@'] = '@@{CATEGORY_VALUE}@@'\nvm_details['metadata']['categories']['AppTier'] = 'SSH'\ndel vm_details['status']\n\n# Prepare payload and headers\npayload = vm_details\nheaders = {'Content-Type': 'application\/json', 'Accept': 'application\/json'}\nurl = 'https:\/\/{}:9440\/api\/nutanix\/v3\/vms\/{}'.format(api_fqdn, vm_uuid)\n\n# Make the request\nresp = requests.put(url, auth=HTTPBasicAuth(api_user, api_pass), json=payload, headers=headers, verify=False)\n\n# Check the response\nif resp.ok:\n    result = resp.json()\n    if '@@{SLA}@@' != 'None':\n        print('SUCCESS: Assigned VM {} to category {}:{}'.format(vm_details['spec']['name'], '@@{CATEGORY_NAME}@@', '@@{CATEGORY_VALUE}@@'))\n    print('SUCCESS: Assigned VM {} to category AppTier:{}'.format(vm_details['spec']['name'], 'SSH'))    \n    exit(0)\nelse:\n    print(resp)\n    print('ERROR: Unable to assign VM to category')\n    exit(1)","script_type":"static_py3","command_line_args":"","exit_status":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"web_frontend","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"6b1041b3_dag_cloned_1_cloned_1","kind":"app_task"},"variable_list":[]},"critical":false},{"type":"fragment","name":"post_action_delete","description":"","runbook":{"name":"ee08f552_runbook","description":"","task_definition_list":[{"type":"DAG","name":"77e954bb_dag","description":"","attrs":{"type":"","edges":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"web_frontend","kind":"app_substrate"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"77e954bb_dag","kind":"app_task"},"variable_list":[]},"critical":false}],"editables":{"create_spec":{"resources":{"disk_list":{"0":{},"1":{}},"boot_config":{"boot_type":false,"boot_device":true},"vtpm_config":{"vtpm_enabled":false}}}},"create_spec":{"type":"","name":"vendure-web","availability_zone_reference":null,"backup_policy":null,"cluster_reference":{"type":"","kind":"cluster","name":"az01app01","uuid":"000630cb-92a6-a024-7d1c-58a2e10e3810"},"resources":{"type":"","nic_list":[{"type":"","nic_type":"NORMAL_NIC","subnet_reference":{"type":"","kind":"subnet","name":"","uuid":"341d53fe-615f-4243-9b74-208d9bc08e04"},"network_function_nic_type":"INGRESS","mac_address":"","ip_endpoint_list":[],"network_function_chain_reference":null,"vpc_reference":{"type":"","kind":"vpc","name":"","uuid":"66d7fa14-da3f-4a98-99ba-2da8608aaf02"}}],"power_state":"ON","guest_tools":null,"num_vcpus_per_socket":1,"num_sockets":4,"memory_size_mib":16384,"gpu_list":[],"parent_reference":null,"hardware_clock_timezone":"","account_uuid":"0f045529-e3cf-4d77-acd2-92413d341ccc","guest_customization":{"type":"","cloud_init":{"type":"","meta_data":"","user_data":"#cloud-config\ntimezone: UTC\ndisable_root: False\nssh_pwauth: True\nhostname: @@{name}@@\nfqdn: @@{name}@@.@@{DOMAIN}@@\n\nusers:\n  - name: @@{cred_linux.username}@@\n    lock_passwd: false\n    sudo: ['ALL=(ALL) NOPASSWD:ALL']\n    ssh-authorized-keys:\n      - @@{OS_CRED_PUBLIC_KEY}@@\n\nchpasswd:\n   list: |\n     @@{cred_linux.username}@@:Nutanix.123\n   expire: false\n\ngrowpart:\n  mode: auto\n  devices: ['\/']\n  ignore_growroot_disabled: false\n\npackage_upgrade: false\n"},"sysprep":null},"boot_config":{"type":"","boot_device":{"type":"","disk_address":{"type":"","device_index":0,"adapter_type":"SCSI"}},"mac_address":"","boot_type":"UEFI"},"vtpm_config":null,"disk_list":[{"type":"","data_source_reference":{"type":"","kind":"app_package","name":"RHEL9","uuid":"e49871d4-e16a-4849-91f6-c03c3dc492d4"},"volume_group_reference":null,"device_properties":{"type":"","disk_address":{"type":"","device_index":0,"adapter_type":"SCSI"},"device_type":"DISK"},"disk_size_mib":102400},{"type":"","data_source_reference":null,"volume_group_reference":null,"device_properties":{"type":"","disk_address":{"type":"","device_index":1,"adapter_type":"SCSI"},"device_type":"DISK"},"disk_size_mib":512000}],"serial_port_list":[]},"categories":{}},"os_type":"Linux","readiness_probe":{"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"},"connection_type":"SSH","connection_port":22,"delay_secs":"30","retries":"5","address":"@@{platform.status.resources.nic_list[0].ip_endpoint_list[0].ip}@@","disable_readiness_probe":false,"connection_protocol":""}}],"package_definition_list":[{"type":"DEB","name":"Package1","description":"","variable_list":[],"action_list":[],"service_local_reference_list":[{"name":"vendure_db","kind":"app_service"}],"version":"","options":{"type":"","install_runbook":{"name":"d6329946_runbook","description":"","task_definition_list":[{"type":"DAG","name":"afe5881e_dag","description":"","attrs":{"type":"","edges":[{"type":"","from_task_reference":{"name":"MountNgt","kind":"app_task"},"to_task_reference":{"name":"InstallNgt","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"DisableSeLinux","kind":"app_task"},"to_task_reference":{"name":"EjectCdrom","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"EjectCdrom","kind":"app_task"},"to_task_reference":{"name":"VmRestart","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"VmRestart","kind":"app_task"},"to_task_reference":{"name":"SatelliteRegister","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"SatelliteRegister","kind":"app_task"},"to_task_reference":{"name":"YumCleanAndInstallPackages","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"YumCleanAndInstallPackages","kind":"app_task"},"to_task_reference":{"name":"InitDataDisk","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InitDataDisk","kind":"app_task"},"to_task_reference":{"name":"InstallPodman","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InstallPodman","kind":"app_task"},"to_task_reference":{"name":"JoinDomain","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"JoinDomain","kind":"app_task"},"to_task_reference":{"name":"InstallPg","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InstallPg","kind":"app_task"},"to_task_reference":{"name":"MountNgt","kind":"app_task"},"edge_type":"user_defined"}]},"child_tasks_local_reference_list":[{"name":"MountNgt","kind":"app_task"},{"name":"InstallNgt","kind":"app_task"},{"name":"SatelliteRegister","kind":"app_task"},{"name":"DisableSeLinux","kind":"app_task"},{"name":"YumCleanAndInstallPackages","kind":"app_task"},{"name":"EjectCdrom","kind":"app_task"},{"name":"InstallPodman","kind":"app_task"},{"name":"InstallPg","kind":"app_task"},{"name":"JoinDomain","kind":"app_task"},{"name":"InitDataDisk","kind":"app_task"},{"name":"VmRestart","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"Package1","kind":"app_package"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"MountNgt","description":"","attrs":{"type":"","script":"#!\/usr\/bin\/python\n################################################\n########     http_requests.py           ########\n################################################\n# import json #tocomment\n# from time import sleep #tocomment\n\nimport requests\n\n\n# For token-based authentication, omit user and password (so that they default to None), and add the following header to\n# the headers list: 'Authorization': 'Bearer <token value>'\ndef process_request(url, method, user=None, password=None, cert=None, files=None,headers=None, payload=None, params=None, secure=False, timeout=120, retries=5, exit_on_failure=True):\n    \"\"\"\n    Processes a web request and handles result appropriately with retries.\n    Returns the content of the web request if successfull.\n    \"\"\"\n    if payload is not None:\n        payload = json.dumps(payload)\n\n    sleep_between_retries=5\n    \n    while retries > 0:\n        try:\n\n            if method == 'GET':\n                response = requests.get(\n                    url,\n                    headers=headers,\n                    auth=(user, password) if user else None,\n                    cert=cert if cert else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'POST':\n                response = requests.post(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'PUT':\n                response = requests.put(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    files=files if files else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'PATCH':\n                response = requests.patch(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'DELETE':\n                response = requests.delete(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n\n        except requests.exceptions.RequestException as error_code:\n            print('Error: {c}, Message: {m}'.format(c = type(error_code).__name__, m = str(error_code)))\n            retries -= 1\n            sleep(sleep_between_retries)\n            continue\n        \n        if response.ok:\n            return response\n        elif response.status_code == 409:\n            print(response.text)\n            retries -= 1\n            if retries == 0:\n                if exit_on_failure:\n                    exit(response.status_code)\n                else:\n                    return response\n            sleep(sleep_between_retries)\n            continue\n        else:\n            print(response.text)\n            if exit_on_failure:\n                exit(response.status_code)\n            else:\n                return response\n\n\n################################################\n############ pc_tasks.py            ############\n################################################\n\n############# Calm imports #################################################################\n# CALM_USES http_requests.py\n############################################################################################\n# from  http_requests import * #tocomment\n# from time import sleep  #tocomment\n\ndef prism_monitor_task_apiv3(api_server,username,passwd,task_uuid,secure=False,exit_on_task_failure=True):\n\n    \"\"\"Given a Prism Central task uuid, loop until the task is completed\n    exits if the task fails\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        task_uuid: Prism Central task uuid (generally returned by another action \n                   performed on PC).\n        secure: boolean to verify or not the api server's certificate (True\/False)\n                   \n    Returns:\n        No value is returned\n    \"\"\"\n    \n    task_status_details = {}\n    task_status = \"RUNNING\"\n\n    headers = {\n    'Content-Type': 'application\/json',\n    'Accept': 'application\/json'\n    }\n    api_server_port = \"9440\"\n    api_server_endpoint = \"\/api\/nutanix\/v3\/tasks\/{0}\".format(task_uuid)\n    url = \"https:\/\/{}:{}{}\".format(\n        api_server,\n        api_server_port,\n        api_server_endpoint\n    )\n    method = \"GET\"\n    print(\"Making a {} API call to {}\".format(method, url))\n    \n    while True:\n        resp = process_request(url,method,user=username,password=passwd,headers=headers,secure=secure)\n        #print(json.loads(resp.content))\n        if resp.ok:\n            task_status_details = json.loads(resp.content)\n            task_status = resp.json()['status']\n            if task_status == \"SUCCEEDED\":\n                print (\"Task has completed successfully\")\n                return task_status_details\n            elif task_status == \"FAILED\":\n                print (\"Task has failed: {}\".format(   resp.json()['error_detail'] if 'error_detail' in resp.json() else \"No Info\" )       )\n                if exit_on_task_failure:\n                    exit(1)\n                else:\n                    return task_status_details\n            else:\n                print (\"Task status is {} and percentage completion is {}. Current step is {}. Waiting for 30 seconds.\".format(task_status,resp.json()['percentage_complete'],resp.json()['progress_message']))\n                sleep(30)\n        else:\n            print(\"Request failed!\")\n            print(\"status code: {}\".format(resp.status_code))\n            print(\"reason: {}\".format(resp.reason))\n            print(\"text: {}\".format(resp.text))\n            print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n            print(\"elapsed: {}\".format(resp.elapsed))\n            print(\"headers: {}\".format(resp.headers))\n            print(json.dumps(\n                json.loads(resp.content),\n                indent=4\n            ))\n            exit(resp.status_code)\n\n    return task_status_details\n\n\ndef monitor_multiple_tasks_apiv3(api_server,username,passwd,task_uuid_list, nb_retries=120, wait_interval=30, secure=False):\n\n    \"\"\"Given a Prism Central list of tasks uuids, loop until all tasks finish or some task fails\n    exits if the one of the tasks fails\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        task_uuid_list: comma-separated list of tasks uuids\n        nb_retries: number of retires before timeout\n        wait_interval: interval between retries in seconds\n        secure: boolean to verify or not the api server's certificate (True\/False)\n\n    Returns:\n        No value is returned\n    \"\"\"\n\n    if task_uuid_list == \"\":\n        return\n    for x in range(nb_retries):\n        tasks_status_list = []\n        for task_uuid in task_uuid_list.split(','):\n            headers = {\n                'Content-Type': 'application\/json',\n                'Accept': 'application\/json'\n            }\n            api_server_port = \"9440\"\n            api_server_endpoint = \"\/api\/nutanix\/v3\/tasks\/{0}\".format(task_uuid)\n            url = \"https:\/\/{}:{}{}\".format(\n                api_server,\n                api_server_port,\n                api_server_endpoint\n            )\n            method = \"GET\"\n            resp = process_request(url=url,method=method,user=username,password=passwd,headers=headers,secure=secure)\n            if resp.ok:\n                task_status_details = json.loads(resp.content)\n                task_status = resp.json()['status']\n            else:\n                print(\"ERROR - Failed to fetch task {} \".format(task_uuid))\n                task_status_details = None\n                task_status = \"Fetch Failed\"\n\n            tasks_status_list.append(\n                {\n                    \"uuid\": task_uuid,\n                    \"state\": task_status,\n                    \"details\" : task_status_details\n                }\n            )\n\n        print(\">>>>> current tasks status:\")\n        overall_state = \"SUCCEEDED\"\n        for task_status in tasks_status_list:\n            print(\"Task UUID : {} \\n\\tStatus :{}\".format(task_status[\"uuid\"],task_status.get(\"state\")))\n            if task_status[\"state\"].upper() == \"FETCH FAILED\":\n                overall_state = \"FAILED\"                \n                print(\"Could not Fetch the Task Status Details \")\n            elif task_status[\"state\"].upper() == \"FAILED\":\n                overall_state = \"FAILED\"\n                print(\"\\tReason for failure : {}\".format(task_status[\"details\"][\"error_detail\"] if 'error_detail' in task_status[\"details\"] else \"No Info\"))\n                print(\"Complete response : {} \".format(task_status[\"details\"]))\n            elif task_status[\"state\"].upper() != \"SUCCEEDED\" and overall_state != \"FAILED\":\n                overall_state = \"inprogress\"\n            for i in range(20): print(\"-\")\n        \n        if overall_state == \"FAILED\":\n            print(\"ERROR - Some Tasks failed. Refer above for the error details\")\n            exit(1)\n        elif overall_state == \"SUCCEEDED\":\n            print(\"INFO - All tasks finished Successfully.\")\n            return\n        else:\n            print(\"INFO - Tasks are still in progress, waiting...\")\n            sleep(wait_interval)\n    #here the monitoring times out\n    print(\"ERROR - Tasks monitoring timed out\")\n    exit(1)\n\n\n\n\n########################################################################\n############       pc_entities.py                           ############\n########################################################################\n# CALM_USES http_requests.py\n# from  http_requests import * #tocomment\n\ndef prism_get_entities(api_server,username,passwd,entity_type,entity_api_root,secure=False,print_f=True,filter=None):\n\n    \"\"\"Retrieve the list of entities from Prism Central.\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        entity_type: kind (type) of entity as referenced in the entity json object\n        entity_api_root: v3 apis root for this entity type. for example. for projects the list api is \"...\/api\/nutanix\/v3\/projects\/list\".\n                         the entity api root here is \"projects\"\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        filter: filter to be applied to the search\n        \n    Returns:\n        An array of entities (entities part of the json response).\n    \"\"\"\n\n    entities = []\n    #region prepare the api call\n    headers = {\n        'Content-Type': 'application\/json',\n        'Accept': 'application\/json'\n    }\n    api_server_port = \"9440\"\n    api_server_endpoint = \"\/api\/nutanix\/v3\/{}\/list\".format(entity_api_root)\n    url = \"https:\/\/{}:{}{}\".format(\n        api_server,\n        api_server_port,\n        api_server_endpoint\n    )\n    method = \"POST\"\n    length = 100\n\n    # Compose the json payload\n    payload = {\n        \"kind\": entity_type,\n        \"offset\": 0,\n        \"length\": length\n    }\n    if filter:\n        payload[\"filter\"] = filter\n    #endregion\n    while True:\n        if print_f:\n            print(\"Making a {} API call to {} with secure set to {}\".format(method, url, secure))\n        resp = process_request(url,method,user=username,password=passwd,headers=headers,payload=payload,secure=secure)\n        # deal with the result\/response\n        if resp.ok:\n            json_resp = json.loads(resp.content)\n            #json_resp = resp\n            entities.extend(json_resp['entities'])\n            key = 'length'\n            if key in json_resp['metadata']:\n                if json_resp['metadata']['length'] == length:\n                    if print_f:\n                        print(\"Processing results from {} to {} out of {}\".format(\n                            json_resp['metadata']['offset'], \n                            json_resp['metadata']['length']+json_resp['metadata']['offset'],\n                            json_resp['metadata']['total_matches']))\n                    payload = {\n                        \"kind\": entity_type,\n                        \"offset\": json_resp['metadata']['length'] + json_resp['metadata']['offset'] + 1,\n                        \"length\": length\n                    }\n                else:\n                    return entities\n            else:\n                return entities\n        else:\n            print(\"Request failed!\")\n            print(\"status code: {}\".format(resp.status_code))\n            print(\"reason: {}\".format(resp.reason))\n            print(\"text: {}\".format(resp.text))\n            print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n            print(\"elapsed: {}\".format(resp.elapsed))\n            print(\"headers: {}\".format(resp.headers))\n            print(\"payload: {}\".format(payload))\n            print(json.dumps(\n                json.loads(resp.content),\n                indent=4\n            ))\n            raise\n\n\ndef prism_get_entity(api_server,username,passwd,entity_type,entity_api_root,entity_name=None,entity_uuid=None,secure=False,print_f=True):\n\n    \"\"\"Returns from Prism Central the uuid and details of a given entity name.\n       If an entity_uuid is specified, it will skip retrieving all entities by specifying the uuid in the arguments (faster).\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        entity_type: kind (type) of entity as referenced in the entity json object\n        entity_api_root: v3 apis root for this entity type. for example. for projects the list api is \"...\/api\/nutanix\/v3\/projects\/list\".\n                         the entity api root here is \"projects\"\n        entity_name: Name of the entity (optional).\n        entity_uuid: Uuid of the entity (optional).\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    Returns:\n        A string containing the UUID of the entity (entity_uuid) and the json content\n        of the entity details (entity_details)\n    \"\"\"\n    \n    entity_details = {}\n\n    if entity_uuid is None:\n        #get the entities list from Prism\n        entity_list = prism_get_entities(api_server=api_server,username=username,passwd=passwd,\n                                          entity_type=entity_type,entity_api_root=entity_api_root,\n                                          secure=secure,print_f=print_f)\n        entity_obj_list = [ entity for entity in entity_list if entity['status']['name'] == entity_name ] \n        if len(entity_obj_list) !=1:\n            print(\"ERROR - found {} instance(s) of the entity {}\".format(len(entity_obj_list),entity_name))\n            exit(1)\n\n        for entity in entity_list:\n            fetched_name = \"\"\n            if \"name\" in entity['spec']:\n                fetched_name = entity['spec']['name']\n            elif \"name\" in entity['status']:\n                fetched_name = entity['status']['name']\n            else:\n                print(\"ERROR - fetched entity name could not be extracted for entity {}\".format(entity['metadata']['uuid']))\n                raise\n            if fetched_name == entity_name:\n                entity_uuid = entity['metadata']['uuid']\n                entity_details = entity.copy()\n                break\n        if entity_details == {} :\n            print(\"ERROR - Entity {} not found\".format(entity_name))\n            exit(1)\n    else:\n        headers = {\n            'Content-Type': 'application\/json',\n            'Accept': 'application\/json'\n        }\n        api_server_port = \"9440\"\n        api_server_endpoint = \"\/api\/nutanix\/v3\/{}\/{}\".format(entity_api_root,entity_uuid)\n        url = \"https:\/\/{}:{}{}\".format(\n            api_server,\n            api_server_port,\n            api_server_endpoint\n        )\n        method = \"GET\"\n        if print_f:\n            print(\"Making a {} API call to {} with secure set to {}\".format(method, url, secure))\n        resp = process_request(url=url,method=method,user=username,password=passwd,headers=headers,secure=secure)\n        if resp.ok:\n            entity_details = json.loads(resp.content)\n        else:\n            print(\"Request failed!\")\n            print(\"status code: {}\".format(resp.status_code))\n            print(\"reason: {}\".format(resp.reason))\n            print(\"text: {}\".format(resp.text))\n            print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n            print(\"elapsed: {}\".format(resp.elapsed))\n            print(\"headers: {}\".format(resp.headers))\n            print(\"payload: {}\".format(payload))\n            print(json.dumps(\n                json.loads(resp.content),\n                indent=4\n            ))\n            raise\n    return entity_uuid, entity_details\n\n\ndef prism_get_entity_uuid(api_server,username,passwd,entity_type,entity_api_root,entity_name=None,secure=False,print_f=True):\n\n    \"\"\"Returns from Prism Central the uuid of a given entity name.\n       \n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        entity_type: kind (type) of entity as referenced in the entity json object\n        entity_api_root: v3 apis root for this entity type. for example. for projects the list api is \"...\/api\/nutanix\/v3\/projects\/list\".\n                         the entity api root here is \"projects\"\n        entity_name: Name of the entity \n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    Returns:\n        A string containing the UUID of the entity (entity_uuid) and the json content\n        of the entity details (entity_details)\n    \"\"\"\n    \n    #get the entities list from Prism\n    entity_list = prism_get_entities(api_server=api_server,username=username,passwd=passwd,\n                                        entity_type=entity_type,entity_api_root=entity_api_root,\n                                        secure=secure,print_f=print_f)\n    entity_uuid = None\n    for entity in entity_list:\n        fetched_name = \"\"\n        if \"name\" in entity['spec']:\n            fetched_name = entity['spec']['name']\n        elif \"name\" in entity['status']:\n            fetched_name = entity['status']['name']\n        else:\n            print(\"ERROR - fetched entity name could not be extracted for entity {}\".format(entity['metadata']['uuid']))\n            raise\n        if fetched_name == entity_name:\n            entity_uuid = entity['metadata']['uuid']\n            break\n    if entity_uuid is None:\n        print(\"Error: Enitity ID could not be retrieved for entity '{}' of kind '{}'\".format(entity_name,entity_type))\n        raise\n    return entity_uuid\n\n\n\n################################################\n############     pc_vm.py          ############\n################################################\n\n############# Calm imports #################################################################\n# CALM_USES pc_entities.py, pc_tasks.py\n############################################################################################\n# from pc_entities import * #tocomment\n# from pc_tasks import * #tocomment\n\nIB_HEADERS = {\n        'Content-Type': 'application\/json',\n        'Accept': 'application\/json'\n    }\n\n\ndef prism_get_vm(api_server,username,passwd,vm_name=None,vm_uuid=None,secure=False,print_f=True):\n    \n    \"\"\"Returns from Prism Central the uuid and details of a given vm name.\n       If a vm_uuid is specified, it will skip retrieving all vms (faster).\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        vm_name: Name of the vm(optional).\n        vm_uuid: Uuid of the vm (optional).\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    Returns:\n        A string containing the UUID of the vm (vm_uuid) and the json content\n        of the vm details (vm_details)\n    \"\"\"\n\n    vm_uuid, vm = prism_get_entity(api_server=api_server,username=username,passwd=passwd,\n                                             entity_type=\"vm\",entity_api_root=\"vms\",entity_name=vm_name,entity_uuid=vm_uuid,\n                                             secure=secure,print_f=print_f)\n    return vm_uuid, vm\n\n\ndef prism_put_vm(api_server,username,passwd,vm_uuid,payload,secure=False):\n    headers = {\n        'Content-Type': 'application\/json',\n        'Accept': 'application\/json'\n    }\n    api_server_port = \"9440\"\n    api_server_endpoint = \"\/api\/nutanix\/v3\/vms\/{}\".format(vm_uuid)\n    url = \"https:\/\/{}:{}{}\".format(\n        api_server,\n        api_server_port,\n        api_server_endpoint\n    )\n    method = \"PUT\"\n    #print(\" VM API PUT call '{}' with payload '{}' \".format(url,payload))\n    resp = process_request(url=url,method=method,user=username,password=passwd,headers=headers,payload=payload,secure=secure)\n    task_uuid = None \n    if resp.ok:\n        print(\"INFO - API PUT call initiated with success for VM : '{}'\".format(vm_uuid))\n        res = json.loads(resp.content)\n        if \"status\" in res and \"execution_context\" in res[\"status\"] \\\n                    and \"task_uuid\" in res[\"status\"][\"execution_context\"]:\n            task_uuid = res[\"status\"][\"execution_context\"][\"task_uuid\"]\n            task_status_details = prism_monitor_task_apiv3(api_server=api_server,username=username,passwd=passwd,secure=secure,task_uuid=task_uuid)\n            return resp, task_status_details\n    elif resp.status_code == 409:\n        return resp, False \n    else:\n        print(\"Request failed!\")\n        print(\"status code: {}\".format(resp.status_code))\n        print(\"reason: {}\".format(resp.reason))\n        print(\"text: {}\".format(resp.text))\n        print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n        print(\"elapsed: {}\".format(resp.elapsed))\n        print(\"headers: {}\".format(resp.headers))\n        print(\"payload: {}\".format(payload))\n        print(json.dumps(\n            json.loads(resp.content),\n            indent=4\n        ))\n        return resp , False \n\n\n\n\ndef prism_mount_enable_ngt_on_vm(api_server,username,passwd,vm_uuid=None,vm_name=None,secure=False,print_f=True):\n    \n    \"\"\"Function to mount and enable NGT on VM\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        vm_name: Name of the vm(optional).\n        vm_uuid: Uuid of the vm (optional).\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    \"\"\"\n    vm_uuid, payload = prism_get_vm(api_server=api_server,username=username,passwd=passwd,vm_uuid=vm_uuid)\n    del payload['status']\n    payload[\"spec\"][\"resources\"].update(\n        {\n            \"guest_tools\": {\n                \"nutanix_guest_tools\": {\n                    \"iso_mount_state\": \"MOUNTED\",\n                    \"state\": \"ENABLED\",\n                    \"enabled_capability_list\": [\"SELF_SERVICE_RESTORE\",\"VSS_SNAPSHOT\"]\n                }\n            }\n        }\n    )\n    resp, task_status_details = prism_put_vm(api_server=api_server,username=username,passwd=passwd,vm_uuid=vm_uuid,payload=payload)\n    return resp, task_status_details\n\n\n\n############# Calm imports #################################################################\n# CALM_USES pc_vm.py\n############################################################################################\n\n### Below lines used for Cyberark cred retrieval ####\n\nPC_PROVIDER_USERNAME = \"@@{prism_central.username}@@\"\nPC_PROVIDER_PASSWD = \"@@{prism_central.secret}@@\"\nPC_PROVIDER_SECURE = False\nPC_PROVIDER_ADDRESS = \"@@{PC_API_FQDN}@@\"\nNGT_INSTALL = \"@@{NGT_INSTALL}@@\"\n\n# region capture Calm macros\nif NGT_INSTALL == \"Yes\":\n    vm_uuid = \"@@{platform.metadata.uuid}@@\"\n    sleep(20)   ############buffer time for VM provision\/ power on\/off ##############\n    prism_mount_enable_ngt_on_vm(api_server=PC_PROVIDER_ADDRESS,username=PC_PROVIDER_USERNAME,passwd=PC_PROVIDER_PASSWD,vm_uuid=vm_uuid)\n    sleep(20)   ############buffer time for VM provision\/ power on\/off ##############","script_type":"static_py3","command_line_args":"","exit_status":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InstallNgt","description":"","attrs":{"type":"","script":"NGT_INSTALL=\"@@{NGT_INSTALL}@@\"\nif [ $NGT_INSTALL = \"Yes\" ]; then\n\tsudo mkdir -p \/tmp\/ngt\n\tmountpt=`sudo blkid | grep -i nutanix | cut -d ':' -f1`\n\tsudo mount $mountpt \/tmp\/ngt\n\techo \"Mount point is $mountpt\"\n\tsudo \/bin\/sh \/tmp\/ngt\/installer\/linux\/install_ngt.sh -o install\n\tsleep 10\n\tsudo umount \/tmp\/ngt\n\texit 0\nfi","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"SatelliteRegister","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n# region headers\n# * author:     haikel.zein@nutanix.com\n# task_name:    RegisterSatellite\n# description:  RegisterSatellite for RHEL 8   \n# updated:\t    20250129\n# description:\tadded error handling and retry logic\n# updated by:   dz@nutanix.com\n# output vars:  none\n# dependencies: none\n# endregion\n\necho \"Satellite Registration\"\nPATH=$PATH:\/bin:\/usr\/bin\nMAX_RETRIES=6\nRETRY_DELAY=10\n\necho \"Beginning vendor registration\"\nfor ((i=1; i<=MAX_RETRIES; i++)); do\n\tif sudo subscription-manager register --username @@{redhat.username}@@ --password @@{redhat.secret}@@ --auto-attach --force; then\n      echo \"Registration successful\"\n      break\n    else\n      echo \"Error: Registration failed with HTTP error code 500: Internal Server Error. Retry $i\/$MAX_RETRIES.\"\n      if [ $i -eq $MAX_RETRIES ]; then\n        echo \"Maximum retries reached. Exiting...\"\n        exit 1\n      fi\n      sleep $RETRY_DELAY\n    fi\n done","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"DisableSeLinux","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n\n# region headers\n# * author:     stephane.bourdeaud@nutanix.com\n# * version:    v1.0\/20210504 - cita-starter version\n# task_name:    DisableSelinux\n# description:  disables enforcement of selinux policy.               \n# output vars:  none\n# dependencies: none\n# endregion\n\nsudo hostnamectl set-hostname --static @@{name}@@\necho \"@@{address}@@  @@{name}@@\" | sudo tee -a \/etc\/hosts\n\n#sudo \/bin\/systemctl stop firewalld || true\n#sudo \/bin\/systemctl disable firewalld || true\n\nsudo sed -i 's\/SELINUX=enforcing\/SELINUX=disabled\/' \/etc\/selinux\/config\nsudo setenforce 0","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"YumCleanAndInstallPackages","description":"","attrs":{"type":"","script":"# this is required or update will fail on filesystem package\nsudo umount \/mnt\n\n# run yum clean\nsudo yum clean all -y\n\n# run yum install lvm2 - required for NGT\nsudo yum install lvm2 jq fio python3 stress-ng -y -q\n\n# set python\nsudo alternatives --set python \/usr\/bin\/python3\npython --version","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"EjectCdrom","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n\n# region headers\n# * author:     stephane.bourdeaud@nutanix.com\n# * version:    v1.0\/20210504 - cita-starter version\n# task_name:    EjectCdrom\n# description:  ejects all cdrom devices (\/dev\/sr*).               \n# output vars:  none\n# dependencies: none\n# endregion\n\nfor device in \/dev\/sr*\ndo \n    sudo eject $device\n    echo \"Ejected ${device}\"\ndone","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InstallPodman","description":"","attrs":{"type":"","script":"sudo dnf install -y podman\npython -m ensurepip --upgrade\npython -m pip install podman-compose\npodman login --username @@{docker.username}@@ --password @@{docker.secret}@@ docker.io\nsudo usermod --add-subuids 100000-165535 @@{cred_linux.username}@@\nsudo usermod --add-subgids 100000-165535 @@{cred_linux.username}@@\nloginctl enable-linger\n","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InstallPg","description":"","attrs":{"type":"","script":"podman volume create pg-data\n\npodman run --name pg -e POSTGRES_PASSWORD=@@{pg.secret}@@ -e POSTGRES_DB=vendure -v pg-data:\/var\/lib\/postgresql\/data --restart always -p 5432:5432 -d docker.io\/library\/postgres:latest\n\npodman generate systemd --new --name pg -f\nmkdir -p ~\/.config\/systemd\/user\/\nmv -v container-pg.service ~\/.config\/systemd\/user\/\nsystemctl --user daemon-reload\nsystemctl --user enable container-pg.service\n","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"JoinDomain","description":"","attrs":{"type":"","script":"#install pre-reqs\nsudo dnf install -y realmd sssd oddjob oddjob-mkhomedir adcli samba-common-tools krb5-workstation\n\n#join domain\nsudo hostnamectl set-hostname @@{name}@@.@@{DOMAIN}@@\nsudo realm discover @@{AD_DOMAIN}@@\necho \"@@{active_directory.secret}@@\" | sudo realm join @@{AD_DOMAIN}@@ --computer-ou=\"@@{AD_OU_PATH}@@\" -U @@{active_directory.username}@@\n\n#enable ddns\necho \"dyndns_update = True\" | sudo tee -a \/etc\/sssd\/sssd.conf\necho \"dyndns_update_ptr = True\" | sudo tee -a \/etc\/sssd\/sssd.conf\necho \"dyndns_refresh_interval = 3600\" | sudo tee -a \/etc\/sssd\/sssd.conf\necho \"dyndns_ttl = 300\" | sudo tee -a \/etc\/sssd\/sssd.conf\nsudo rm -f \/var\/lib\/sss\/db\/*\nsudo systemctl restart sssd","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InitDataDisk","description":"","attrs":{"type":"","script":"# region headers\n# * author:     stephane.bourdeaud@nutanix.com\n# * version:    v1.0\/20230516 - rhel 8 version\n# task_name:    InitializeDataDisk\n# description:  configured \/dev\/sdb1 as an lvm volume, formats it\n#               as ext4 and mounts it in the specified mountpoint, \n#               also configuring fstab.               \n# output vars:  none\n# dependencies: none\n# endregion\n\n#sudo yum install -y lvm2 jq\nfree_device=$(lsblk --json | jq -r '.blockdevices[] | select(.type == \"disk\" and (.children | length == 0 or not .children?)) | .name' | while read DISK_NAME; do echo \"\/dev\/$DISK_NAME\"; done)\nfree_partition=\"${free_device}1\"\nprintf 'o\\nn\\np\\n\\n\\n\\nt\\n8e\\nw' | sudo fdisk $free_device\nsudo pvcreate $free_partition\nsudo vgcreate vg0 $free_partition\nsudo lvcreate -n data -l 100%FREE vg0\nsudo mkfs.ext4 \/dev\/vg0\/data\nsudo mkdir -p @@{DB_DATA_DISK_MOUNTPOINT}@@\nsudo mount \/dev\/vg0\/data @@{DB_DATA_DISK_MOUNTPOINT}@@\necho '\/dev\/mapper\/vg0-data @@{DB_DATA_DISK_MOUNTPOINT}@@ ext4 defaults 0 0' | sudo tee -a \/etc\/fstab\nsudo chown -R @@{cred_linux.username}@@:@@{cred_linux.username}@@ @@{DB_DATA_DISK_MOUNTPOINT}@@\nsudo chmod -R 755 @@{DB_DATA_DISK_MOUNTPOINT}@@","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"CALL_RUNBOOK","name":"VmRestart","description":"","attrs":{"type":"CALL_RUNBOOK","runbook_reference":{"name":"SYS_GEN__substrate__db_backend__action_restart__runbook","kind":"app_runbook"},"inarg_list":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"afe5881e_dag","kind":"app_task"},"variable_list":[]},"uninstall_runbook":{"name":"bc5b8df7_runbook","description":"","task_definition_list":[{"type":"DAG","name":"d6e8deba_dag","description":"","attrs":{"type":"","edges":[{"type":"","from_task_reference":{"name":"SatelliteUnregister","kind":"app_task"},"to_task_reference":{"name":"UnjoinDomain","kind":"app_task"},"edge_type":"user_defined"}]},"child_tasks_local_reference_list":[{"name":"SatelliteUnregister","kind":"app_task"},{"name":"UnjoinDomain","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"Package1","kind":"app_package"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"SatelliteUnregister","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n# region headers\n# * author:     haikel.zein@nutanix.com\n# task_name:    RegisterSatellite\n# description:  RegisterSatellite for RHEL 8   \n# output vars:  none\n# dependencies: none\n# endregion\n\necho \"Satellite Registration\"\nPATH=$PATH:\/bin:\/usr\/bin\nMYDIR=`dirname ${0}`\n\necho \"beginning vendor unregistration\"\nsudo subscription-manager unregister","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"UnjoinDomain","description":"","attrs":{"type":"","script":"#leave domain\necho \"@@{active_directory.secret}@@\" | sudo realm leave --remove -U @@{active_directory.username}@@ @@{AD_DOMAIN}@@","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_db","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"d6e8deba_dag","kind":"app_task"},"variable_list":[]},"upgrade_runbook":{}}},{"type":"SUBSTRATE_IMAGE","name":"RHEL9","description":"","variable_list":[],"action_list":[],"service_local_reference_list":[],"version":"","options":{"type":"","name":"RHEL9","resources":{"type":"","image_type":"DISK_IMAGE","checksum":{},"source_uri":"http:\/\/httpd.emeagso.lab\/download\/images\/rhel9-cloud-image.qcow2","version":{"type":"","product_version":"9","product_name":"RedHat Enterprise Linux"},"architecture":"X86_64"},"description":""}},{"type":"DEB","name":"Package1_cloned_0","description":"","variable_list":[],"action_list":[],"service_local_reference_list":[{"name":"vendure_app","kind":"app_service"}],"version":"","options":{"type":"","install_runbook":{"name":"d6329946_runbook_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"afe5881e_dag_cloned_1","description":"","attrs":{"type":"","edges":[{"type":"","from_task_reference":{"name":"MountNgt1","kind":"app_task"},"to_task_reference":{"name":"InstallNgt1","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InitDataDisk1","kind":"app_task"},"to_task_reference":{"name":"InstallPodman1","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"DisableSeLinux1","kind":"app_task"},"to_task_reference":{"name":"EjectCdrom1","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"EjectCdrom1","kind":"app_task"},"to_task_reference":{"name":"VmRestart1","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"VmRestart1","kind":"app_task"},"to_task_reference":{"name":"SatelliteRegister1","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"SatelliteRegister1","kind":"app_task"},"to_task_reference":{"name":"YumCleanAndInstallPackages1","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"YumCleanAndInstallPackages1","kind":"app_task"},"to_task_reference":{"name":"InitDataDisk1","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InitDataDisk1","kind":"app_task"},"to_task_reference":{"name":"InstallPodman1","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InstallPodman1","kind":"app_task"},"to_task_reference":{"name":"JoinDomain1","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"JoinDomain1","kind":"app_task"},"to_task_reference":{"name":"MountNgt1","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InstallNgt1","kind":"app_task"},"to_task_reference":{"name":"InstallNpm","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InstallNpm","kind":"app_task"},"to_task_reference":{"name":"InstallVendureApp","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InstallNpm","kind":"app_task"},"to_task_reference":{"name":"InstallVendureApp","kind":"app_task"},"edge_type":"user_defined"}]},"child_tasks_local_reference_list":[{"name":"MountNgt1","kind":"app_task"},{"name":"InstallNgt1","kind":"app_task"},{"name":"SatelliteRegister1","kind":"app_task"},{"name":"DisableSeLinux1","kind":"app_task"},{"name":"YumCleanAndInstallPackages1","kind":"app_task"},{"name":"EjectCdrom1","kind":"app_task"},{"name":"InstallPodman1","kind":"app_task"},{"name":"JoinDomain1","kind":"app_task"},{"name":"InitDataDisk1","kind":"app_task"},{"name":"VmRestart1","kind":"app_task"},{"name":"InstallNpm","kind":"app_task"},{"name":"InstallVendureApp","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"Package1_cloned_0","kind":"app_package"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"MountNgt1","description":"","attrs":{"type":"","script":"#!\/usr\/bin\/python\n################################################\n########     http_requests.py           ########\n################################################\n# import json #tocomment\n# from time import sleep #tocomment\n\nimport requests\n\n\n# For token-based authentication, omit user and password (so that they default to None), and add the following header to\n# the headers list: 'Authorization': 'Bearer <token value>'\ndef process_request(url, method, user=None, password=None, cert=None, files=None,headers=None, payload=None, params=None, secure=False, timeout=120, retries=5, exit_on_failure=True):\n    \"\"\"\n    Processes a web request and handles result appropriately with retries.\n    Returns the content of the web request if successfull.\n    \"\"\"\n    if payload is not None:\n        payload = json.dumps(payload)\n\n    sleep_between_retries=5\n    \n    while retries > 0:\n        try:\n\n            if method == 'GET':\n                response = requests.get(\n                    url,\n                    headers=headers,\n                    auth=(user, password) if user else None,\n                    cert=cert if cert else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'POST':\n                response = requests.post(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'PUT':\n                response = requests.put(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    files=files if files else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'PATCH':\n                response = requests.patch(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'DELETE':\n                response = requests.delete(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n\n        except requests.exceptions.RequestException as error_code:\n            print('Error: {c}, Message: {m}'.format(c = type(error_code).__name__, m = str(error_code)))\n            retries -= 1\n            sleep(sleep_between_retries)\n            continue\n        \n        if response.ok:\n            return response\n        elif response.status_code == 409:\n            print(response.text)\n            retries -= 1\n            if retries == 0:\n                if exit_on_failure:\n                    exit(response.status_code)\n                else:\n                    return response\n            sleep(sleep_between_retries)\n            continue\n        else:\n            print(response.text)\n            if exit_on_failure:\n                exit(response.status_code)\n            else:\n                return response\n\n\n################################################\n############ pc_tasks.py            ############\n################################################\n\n############# Calm imports #################################################################\n# CALM_USES http_requests.py\n############################################################################################\n# from  http_requests import * #tocomment\n# from time import sleep  #tocomment\n\ndef prism_monitor_task_apiv3(api_server,username,passwd,task_uuid,secure=False,exit_on_task_failure=True):\n\n    \"\"\"Given a Prism Central task uuid, loop until the task is completed\n    exits if the task fails\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        task_uuid: Prism Central task uuid (generally returned by another action \n                   performed on PC).\n        secure: boolean to verify or not the api server's certificate (True\/False)\n                   \n    Returns:\n        No value is returned\n    \"\"\"\n    \n    task_status_details = {}\n    task_status = \"RUNNING\"\n\n    headers = {\n    'Content-Type': 'application\/json',\n    'Accept': 'application\/json'\n    }\n    api_server_port = \"9440\"\n    api_server_endpoint = \"\/api\/nutanix\/v3\/tasks\/{0}\".format(task_uuid)\n    url = \"https:\/\/{}:{}{}\".format(\n        api_server,\n        api_server_port,\n        api_server_endpoint\n    )\n    method = \"GET\"\n    print(\"Making a {} API call to {}\".format(method, url))\n    \n    while True:\n        resp = process_request(url,method,user=username,password=passwd,headers=headers,secure=secure)\n        #print(json.loads(resp.content))\n        if resp.ok:\n            task_status_details = json.loads(resp.content)\n            task_status = resp.json()['status']\n            if task_status == \"SUCCEEDED\":\n                print (\"Task has completed successfully\")\n                return task_status_details\n            elif task_status == \"FAILED\":\n                print (\"Task has failed: {}\".format(   resp.json()['error_detail'] if 'error_detail' in resp.json() else \"No Info\" )       )\n                if exit_on_task_failure:\n                    exit(1)\n                else:\n                    return task_status_details\n            else:\n                print (\"Task status is {} and percentage completion is {}. Current step is {}. Waiting for 30 seconds.\".format(task_status,resp.json()['percentage_complete'],resp.json()['progress_message']))\n                sleep(30)\n        else:\n            print(\"Request failed!\")\n            print(\"status code: {}\".format(resp.status_code))\n            print(\"reason: {}\".format(resp.reason))\n            print(\"text: {}\".format(resp.text))\n            print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n            print(\"elapsed: {}\".format(resp.elapsed))\n            print(\"headers: {}\".format(resp.headers))\n            print(json.dumps(\n                json.loads(resp.content),\n                indent=4\n            ))\n            exit(resp.status_code)\n\n    return task_status_details\n\n\ndef monitor_multiple_tasks_apiv3(api_server,username,passwd,task_uuid_list, nb_retries=120, wait_interval=30, secure=False):\n\n    \"\"\"Given a Prism Central list of tasks uuids, loop until all tasks finish or some task fails\n    exits if the one of the tasks fails\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        task_uuid_list: comma-separated list of tasks uuids\n        nb_retries: number of retires before timeout\n        wait_interval: interval between retries in seconds\n        secure: boolean to verify or not the api server's certificate (True\/False)\n\n    Returns:\n        No value is returned\n    \"\"\"\n\n    if task_uuid_list == \"\":\n        return\n    for x in range(nb_retries):\n        tasks_status_list = []\n        for task_uuid in task_uuid_list.split(','):\n            headers = {\n                'Content-Type': 'application\/json',\n                'Accept': 'application\/json'\n            }\n            api_server_port = \"9440\"\n            api_server_endpoint = \"\/api\/nutanix\/v3\/tasks\/{0}\".format(task_uuid)\n            url = \"https:\/\/{}:{}{}\".format(\n                api_server,\n                api_server_port,\n                api_server_endpoint\n            )\n            method = \"GET\"\n            resp = process_request(url=url,method=method,user=username,password=passwd,headers=headers,secure=secure)\n            if resp.ok:\n                task_status_details = json.loads(resp.content)\n                task_status = resp.json()['status']\n            else:\n                print(\"ERROR - Failed to fetch task {} \".format(task_uuid))\n                task_status_details = None\n                task_status = \"Fetch Failed\"\n\n            tasks_status_list.append(\n                {\n                    \"uuid\": task_uuid,\n                    \"state\": task_status,\n                    \"details\" : task_status_details\n                }\n            )\n\n        print(\">>>>> current tasks status:\")\n        overall_state = \"SUCCEEDED\"\n        for task_status in tasks_status_list:\n            print(\"Task UUID : {} \\n\\tStatus :{}\".format(task_status[\"uuid\"],task_status.get(\"state\")))\n            if task_status[\"state\"].upper() == \"FETCH FAILED\":\n                overall_state = \"FAILED\"                \n                print(\"Could not Fetch the Task Status Details \")\n            elif task_status[\"state\"].upper() == \"FAILED\":\n                overall_state = \"FAILED\"\n                print(\"\\tReason for failure : {}\".format(task_status[\"details\"][\"error_detail\"] if 'error_detail' in task_status[\"details\"] else \"No Info\"))\n                print(\"Complete response : {} \".format(task_status[\"details\"]))\n            elif task_status[\"state\"].upper() != \"SUCCEEDED\" and overall_state != \"FAILED\":\n                overall_state = \"inprogress\"\n            for i in range(20): print(\"-\")\n        \n        if overall_state == \"FAILED\":\n            print(\"ERROR - Some Tasks failed. Refer above for the error details\")\n            exit(1)\n        elif overall_state == \"SUCCEEDED\":\n            print(\"INFO - All tasks finished Successfully.\")\n            return\n        else:\n            print(\"INFO - Tasks are still in progress, waiting...\")\n            sleep(wait_interval)\n    #here the monitoring times out\n    print(\"ERROR - Tasks monitoring timed out\")\n    exit(1)\n\n\n\n\n########################################################################\n############       pc_entities.py                           ############\n########################################################################\n# CALM_USES http_requests.py\n# from  http_requests import * #tocomment\n\ndef prism_get_entities(api_server,username,passwd,entity_type,entity_api_root,secure=False,print_f=True,filter=None):\n\n    \"\"\"Retrieve the list of entities from Prism Central.\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        entity_type: kind (type) of entity as referenced in the entity json object\n        entity_api_root: v3 apis root for this entity type. for example. for projects the list api is \"...\/api\/nutanix\/v3\/projects\/list\".\n                         the entity api root here is \"projects\"\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        filter: filter to be applied to the search\n        \n    Returns:\n        An array of entities (entities part of the json response).\n    \"\"\"\n\n    entities = []\n    #region prepare the api call\n    headers = {\n        'Content-Type': 'application\/json',\n        'Accept': 'application\/json'\n    }\n    api_server_port = \"9440\"\n    api_server_endpoint = \"\/api\/nutanix\/v3\/{}\/list\".format(entity_api_root)\n    url = \"https:\/\/{}:{}{}\".format(\n        api_server,\n        api_server_port,\n        api_server_endpoint\n    )\n    method = \"POST\"\n    length = 100\n\n    # Compose the json payload\n    payload = {\n        \"kind\": entity_type,\n        \"offset\": 0,\n        \"length\": length\n    }\n    if filter:\n        payload[\"filter\"] = filter\n    #endregion\n    while True:\n        if print_f:\n            print(\"Making a {} API call to {} with secure set to {}\".format(method, url, secure))\n        resp = process_request(url,method,user=username,password=passwd,headers=headers,payload=payload,secure=secure)\n        # deal with the result\/response\n        if resp.ok:\n            json_resp = json.loads(resp.content)\n            #json_resp = resp\n            entities.extend(json_resp['entities'])\n            key = 'length'\n            if key in json_resp['metadata']:\n                if json_resp['metadata']['length'] == length:\n                    if print_f:\n                        print(\"Processing results from {} to {} out of {}\".format(\n                            json_resp['metadata']['offset'], \n                            json_resp['metadata']['length']+json_resp['metadata']['offset'],\n                            json_resp['metadata']['total_matches']))\n                    payload = {\n                        \"kind\": entity_type,\n                        \"offset\": json_resp['metadata']['length'] + json_resp['metadata']['offset'] + 1,\n                        \"length\": length\n                    }\n                else:\n                    return entities\n            else:\n                return entities\n        else:\n            print(\"Request failed!\")\n            print(\"status code: {}\".format(resp.status_code))\n            print(\"reason: {}\".format(resp.reason))\n            print(\"text: {}\".format(resp.text))\n            print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n            print(\"elapsed: {}\".format(resp.elapsed))\n            print(\"headers: {}\".format(resp.headers))\n            print(\"payload: {}\".format(payload))\n            print(json.dumps(\n                json.loads(resp.content),\n                indent=4\n            ))\n            raise\n\n\ndef prism_get_entity(api_server,username,passwd,entity_type,entity_api_root,entity_name=None,entity_uuid=None,secure=False,print_f=True):\n\n    \"\"\"Returns from Prism Central the uuid and details of a given entity name.\n       If an entity_uuid is specified, it will skip retrieving all entities by specifying the uuid in the arguments (faster).\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        entity_type: kind (type) of entity as referenced in the entity json object\n        entity_api_root: v3 apis root for this entity type. for example. for projects the list api is \"...\/api\/nutanix\/v3\/projects\/list\".\n                         the entity api root here is \"projects\"\n        entity_name: Name of the entity (optional).\n        entity_uuid: Uuid of the entity (optional).\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    Returns:\n        A string containing the UUID of the entity (entity_uuid) and the json content\n        of the entity details (entity_details)\n    \"\"\"\n    \n    entity_details = {}\n\n    if entity_uuid is None:\n        #get the entities list from Prism\n        entity_list = prism_get_entities(api_server=api_server,username=username,passwd=passwd,\n                                          entity_type=entity_type,entity_api_root=entity_api_root,\n                                          secure=secure,print_f=print_f)\n        entity_obj_list = [ entity for entity in entity_list if entity['status']['name'] == entity_name ] \n        if len(entity_obj_list) !=1:\n            print(\"ERROR - found {} instance(s) of the entity {}\".format(len(entity_obj_list),entity_name))\n            exit(1)\n\n        for entity in entity_list:\n            fetched_name = \"\"\n            if \"name\" in entity['spec']:\n                fetched_name = entity['spec']['name']\n            elif \"name\" in entity['status']:\n                fetched_name = entity['status']['name']\n            else:\n                print(\"ERROR - fetched entity name could not be extracted for entity {}\".format(entity['metadata']['uuid']))\n                raise\n            if fetched_name == entity_name:\n                entity_uuid = entity['metadata']['uuid']\n                entity_details = entity.copy()\n                break\n        if entity_details == {} :\n            print(\"ERROR - Entity {} not found\".format(entity_name))\n            exit(1)\n    else:\n        headers = {\n            'Content-Type': 'application\/json',\n            'Accept': 'application\/json'\n        }\n        api_server_port = \"9440\"\n        api_server_endpoint = \"\/api\/nutanix\/v3\/{}\/{}\".format(entity_api_root,entity_uuid)\n        url = \"https:\/\/{}:{}{}\".format(\n            api_server,\n            api_server_port,\n            api_server_endpoint\n        )\n        method = \"GET\"\n        if print_f:\n            print(\"Making a {} API call to {} with secure set to {}\".format(method, url, secure))\n        resp = process_request(url=url,method=method,user=username,password=passwd,headers=headers,secure=secure)\n        if resp.ok:\n            entity_details = json.loads(resp.content)\n        else:\n            print(\"Request failed!\")\n            print(\"status code: {}\".format(resp.status_code))\n            print(\"reason: {}\".format(resp.reason))\n            print(\"text: {}\".format(resp.text))\n            print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n            print(\"elapsed: {}\".format(resp.elapsed))\n            print(\"headers: {}\".format(resp.headers))\n            print(\"payload: {}\".format(payload))\n            print(json.dumps(\n                json.loads(resp.content),\n                indent=4\n            ))\n            raise\n    return entity_uuid, entity_details\n\n\ndef prism_get_entity_uuid(api_server,username,passwd,entity_type,entity_api_root,entity_name=None,secure=False,print_f=True):\n\n    \"\"\"Returns from Prism Central the uuid of a given entity name.\n       \n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        entity_type: kind (type) of entity as referenced in the entity json object\n        entity_api_root: v3 apis root for this entity type. for example. for projects the list api is \"...\/api\/nutanix\/v3\/projects\/list\".\n                         the entity api root here is \"projects\"\n        entity_name: Name of the entity \n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    Returns:\n        A string containing the UUID of the entity (entity_uuid) and the json content\n        of the entity details (entity_details)\n    \"\"\"\n    \n    #get the entities list from Prism\n    entity_list = prism_get_entities(api_server=api_server,username=username,passwd=passwd,\n                                        entity_type=entity_type,entity_api_root=entity_api_root,\n                                        secure=secure,print_f=print_f)\n    entity_uuid = None\n    for entity in entity_list:\n        fetched_name = \"\"\n        if \"name\" in entity['spec']:\n            fetched_name = entity['spec']['name']\n        elif \"name\" in entity['status']:\n            fetched_name = entity['status']['name']\n        else:\n            print(\"ERROR - fetched entity name could not be extracted for entity {}\".format(entity['metadata']['uuid']))\n            raise\n        if fetched_name == entity_name:\n            entity_uuid = entity['metadata']['uuid']\n            break\n    if entity_uuid is None:\n        print(\"Error: Enitity ID could not be retrieved for entity '{}' of kind '{}'\".format(entity_name,entity_type))\n        raise\n    return entity_uuid\n\n\n\n################################################\n############     pc_vm.py          ############\n################################################\n\n############# Calm imports #################################################################\n# CALM_USES pc_entities.py, pc_tasks.py\n############################################################################################\n# from pc_entities import * #tocomment\n# from pc_tasks import * #tocomment\n\nIB_HEADERS = {\n        'Content-Type': 'application\/json',\n        'Accept': 'application\/json'\n    }\n\n\ndef prism_get_vm(api_server,username,passwd,vm_name=None,vm_uuid=None,secure=False,print_f=True):\n    \n    \"\"\"Returns from Prism Central the uuid and details of a given vm name.\n       If a vm_uuid is specified, it will skip retrieving all vms (faster).\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        vm_name: Name of the vm(optional).\n        vm_uuid: Uuid of the vm (optional).\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    Returns:\n        A string containing the UUID of the vm (vm_uuid) and the json content\n        of the vm details (vm_details)\n    \"\"\"\n\n    vm_uuid, vm = prism_get_entity(api_server=api_server,username=username,passwd=passwd,\n                                             entity_type=\"vm\",entity_api_root=\"vms\",entity_name=vm_name,entity_uuid=vm_uuid,\n                                             secure=secure,print_f=print_f)\n    return vm_uuid, vm\n\n\ndef prism_put_vm(api_server,username,passwd,vm_uuid,payload,secure=False):\n    headers = {\n        'Content-Type': 'application\/json',\n        'Accept': 'application\/json'\n    }\n    api_server_port = \"9440\"\n    api_server_endpoint = \"\/api\/nutanix\/v3\/vms\/{}\".format(vm_uuid)\n    url = \"https:\/\/{}:{}{}\".format(\n        api_server,\n        api_server_port,\n        api_server_endpoint\n    )\n    method = \"PUT\"\n    #print(\" VM API PUT call '{}' with payload '{}' \".format(url,payload))\n    resp = process_request(url=url,method=method,user=username,password=passwd,headers=headers,payload=payload,secure=secure)\n    task_uuid = None \n    if resp.ok:\n        print(\"INFO - API PUT call initiated with success for VM : '{}'\".format(vm_uuid))\n        res = json.loads(resp.content)\n        if \"status\" in res and \"execution_context\" in res[\"status\"] \\\n                    and \"task_uuid\" in res[\"status\"][\"execution_context\"]:\n            task_uuid = res[\"status\"][\"execution_context\"][\"task_uuid\"]\n            task_status_details = prism_monitor_task_apiv3(api_server=api_server,username=username,passwd=passwd,secure=secure,task_uuid=task_uuid)\n            return resp, task_status_details\n    elif resp.status_code == 409:\n        return resp, False \n    else:\n        print(\"Request failed!\")\n        print(\"status code: {}\".format(resp.status_code))\n        print(\"reason: {}\".format(resp.reason))\n        print(\"text: {}\".format(resp.text))\n        print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n        print(\"elapsed: {}\".format(resp.elapsed))\n        print(\"headers: {}\".format(resp.headers))\n        print(\"payload: {}\".format(payload))\n        print(json.dumps(\n            json.loads(resp.content),\n            indent=4\n        ))\n        return resp , False \n\n\n\n\ndef prism_mount_enable_ngt_on_vm(api_server,username,passwd,vm_uuid=None,vm_name=None,secure=False,print_f=True):\n    \n    \"\"\"Function to mount and enable NGT on VM\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        vm_name: Name of the vm(optional).\n        vm_uuid: Uuid of the vm (optional).\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    \"\"\"\n    vm_uuid, payload = prism_get_vm(api_server=api_server,username=username,passwd=passwd,vm_uuid=vm_uuid)\n    del payload['status']\n    payload[\"spec\"][\"resources\"].update(\n        {\n            \"guest_tools\": {\n                \"nutanix_guest_tools\": {\n                    \"iso_mount_state\": \"MOUNTED\",\n                    \"state\": \"ENABLED\",\n                    \"enabled_capability_list\": [\"SELF_SERVICE_RESTORE\",\"VSS_SNAPSHOT\"]\n                }\n            }\n        }\n    )\n    resp, task_status_details = prism_put_vm(api_server=api_server,username=username,passwd=passwd,vm_uuid=vm_uuid,payload=payload)\n    return resp, task_status_details\n\n\n\n############# Calm imports #################################################################\n# CALM_USES pc_vm.py\n############################################################################################\n\n### Below lines used for Cyberark cred retrieval ####\n\nPC_PROVIDER_USERNAME = \"@@{prism_central.username}@@\"\nPC_PROVIDER_PASSWD = \"@@{prism_central.secret}@@\"\nPC_PROVIDER_SECURE = False\nPC_PROVIDER_ADDRESS = \"@@{PC_API_FQDN}@@\"\nNGT_INSTALL = \"@@{NGT_INSTALL}@@\"\n\n# region capture Calm macros\nif NGT_INSTALL == \"Yes\":\n    vm_uuid = \"@@{platform.metadata.uuid}@@\"\n    sleep(20)   ############buffer time for VM provision\/ power on\/off ##############\n    prism_mount_enable_ngt_on_vm(api_server=PC_PROVIDER_ADDRESS,username=PC_PROVIDER_USERNAME,passwd=PC_PROVIDER_PASSWD,vm_uuid=vm_uuid)\n    sleep(20)   ############buffer time for VM provision\/ power on\/off ##############","script_type":"static_py3","command_line_args":"","exit_status":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InstallNgt1","description":"","attrs":{"type":"","script":"NGT_INSTALL=\"@@{NGT_INSTALL}@@\"\nif [ $NGT_INSTALL = \"Yes\" ]; then\n\tsudo mkdir -p \/tmp\/ngt\n\tmountpt=`sudo blkid | grep -i nutanix | cut -d ':' -f1`\n\tsudo mount $mountpt \/tmp\/ngt\n\techo \"Mount point is $mountpt\"\n\tsudo \/bin\/sh \/tmp\/ngt\/installer\/linux\/install_ngt.sh -o install\n\tsleep 10\n\tsudo umount \/tmp\/ngt\n\texit 0\nfi","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"SatelliteRegister1","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n# region headers\n# * author:     haikel.zein@nutanix.com\n# task_name:    RegisterSatellite\n# description:  RegisterSatellite for RHEL 8   \n# updated:\t    20250129\n# description:\tadded error handling and retry logic\n# updated by:   dz@nutanix.com\n# output vars:  none\n# dependencies: none\n# endregion\n\necho \"Satellite Registration\"\nPATH=$PATH:\/bin:\/usr\/bin\nMAX_RETRIES=6\nRETRY_DELAY=10\n\necho \"Beginning vendor registration\"\nfor ((i=1; i<=MAX_RETRIES; i++)); do\n\tif sudo subscription-manager register --username @@{redhat.username}@@ --password @@{redhat.secret}@@ --auto-attach --force; then\n      echo \"Registration successful\"\n      break\n    else\n      echo \"Error: Registration failed with HTTP error code 500: Internal Server Error. Retry $i\/$MAX_RETRIES.\"\n      if [ $i -eq $MAX_RETRIES ]; then\n        echo \"Maximum retries reached. Exiting...\"\n        exit 1\n      fi\n      sleep $RETRY_DELAY\n    fi\n done","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"DisableSeLinux1","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n\n# region headers\n# * author:     stephane.bourdeaud@nutanix.com\n# * version:    v1.0\/20210504 - cita-starter version\n# task_name:    DisableSelinux\n# description:  disables enforcement of selinux policy.               \n# output vars:  none\n# dependencies: none\n# endregion\n\nsudo hostnamectl set-hostname --static @@{name}@@\necho \"@@{address}@@  @@{name}@@\" | sudo tee -a \/etc\/hosts\n\n#sudo \/bin\/systemctl stop firewalld || true\n#sudo \/bin\/systemctl disable firewalld || true\n\nsudo sed -i 's\/SELINUX=enforcing\/SELINUX=disabled\/' \/etc\/selinux\/config\nsudo setenforce 0","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"YumCleanAndInstallPackages1","description":"","attrs":{"type":"","script":"# this is required or update will fail on filesystem package\nsudo umount \/mnt\n\n# run yum clean\nsudo yum clean all -y\n\n# run yum install lvm2 - required for NGT\nsudo yum install lvm2 jq fio python3 stress-ng -y -q\n\n# set python\nsudo alternatives --set python \/usr\/bin\/python3\npython --version","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"EjectCdrom1","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n\n# region headers\n# * author:     stephane.bourdeaud@nutanix.com\n# * version:    v1.0\/20210504 - cita-starter version\n# task_name:    EjectCdrom\n# description:  ejects all cdrom devices (\/dev\/sr*).               \n# output vars:  none\n# dependencies: none\n# endregion\n\nfor device in \/dev\/sr*\ndo \n    sudo eject $device\n    echo \"Ejected ${device}\"\ndone","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InstallPodman1","description":"","attrs":{"type":"","script":"sudo dnf install -y podman\npython -m ensurepip --upgrade\npython -m pip install podman-compose\npodman login --username @@{docker.username}@@ --password @@{docker.secret}@@ docker.io\nsudo usermod --add-subuids 100000-165535 @@{cred_linux.username}@@\nsudo usermod --add-subgids 100000-165535 @@{cred_linux.username}@@\nloginctl enable-linger\n","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"JoinDomain1","description":"","attrs":{"type":"","script":"#install pre-reqs\nsudo dnf install -y realmd sssd oddjob oddjob-mkhomedir adcli samba-common-tools krb5-workstation\n\n#join domain\nsudo hostnamectl set-hostname @@{name}@@.@@{DOMAIN}@@\nsudo realm discover @@{AD_DOMAIN}@@\necho \"@@{active_directory.secret}@@\" | sudo realm join @@{AD_DOMAIN}@@ --computer-ou=\"@@{AD_OU_PATH}@@\" -U @@{active_directory.username}@@\n\n#enable ddns\necho \"dyndns_update = True\" | sudo tee -a \/etc\/sssd\/sssd.conf\necho \"dyndns_update_ptr = True\" | sudo tee -a \/etc\/sssd\/sssd.conf\necho \"dyndns_refresh_interval = 3600\" | sudo tee -a \/etc\/sssd\/sssd.conf\necho \"dyndns_ttl = 300\" | sudo tee -a \/etc\/sssd\/sssd.conf\nsudo rm -f \/var\/lib\/sss\/db\/*\nsudo systemctl restart sssd","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InitDataDisk1","description":"","attrs":{"type":"","script":"# region headers\n# * author:     stephane.bourdeaud@nutanix.com\n# * version:    v1.0\/20230516 - rhel 8 version\n# task_name:    InitializeDataDisk\n# description:  configured \/dev\/sdb1 as an lvm volume, formats it\n#               as ext4 and mounts it in the specified mountpoint, \n#               also configuring fstab.               \n# output vars:  none\n# dependencies: none\n# endregion\n\n#sudo yum install -y lvm2 jq\nfree_device=$(lsblk --json | jq -r '.blockdevices[] | select(.type == \"disk\" and (.children | length == 0 or not .children?)) | .name' | while read DISK_NAME; do echo \"\/dev\/$DISK_NAME\"; done)\nfree_partition=\"${free_device}1\"\nprintf 'o\\nn\\np\\n\\n\\n\\nt\\n8e\\nw' | sudo fdisk $free_device\nsudo pvcreate $free_partition\nsudo vgcreate vg0 $free_partition\nsudo lvcreate -n data -l 100%FREE vg0\nsudo mkfs.ext4 \/dev\/vg0\/data\nsudo mkdir -p @@{APP_DATA_DISK_MOUNTPOINT}@@\nsudo mount \/dev\/vg0\/data @@{APP_DATA_DISK_MOUNTPOINT}@@\necho '\/dev\/mapper\/vg0-data @@{APP_DATA_DISK_MOUNTPOINT}@@ ext4 defaults 0 0' | sudo tee -a \/etc\/fstab\nsudo chown -R @@{cred_linux.username}@@:@@{cred_linux.username}@@ @@{APP_DATA_DISK_MOUNTPOINT}@@\nsudo chmod -R 755 @@{APP_DATA_DISK_MOUNTPOINT}@@","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"CALL_RUNBOOK","name":"VmRestart1","description":"","attrs":{"type":"CALL_RUNBOOK","runbook_reference":{"name":"SYS_GEN__substrate__web_app__action_restart__runbook","kind":"app_runbook"},"inarg_list":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InstallNpm","description":"","attrs":{"type":"","script":"# Install Node.js v20\nsudo dnf module enable nodejs:20 -y\nsudo dnf install nodejs -y","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InstallVendureApp","description":"","attrs":{"type":"","script":"export APP_ENV=production\nexport PORT=3000\nexport COOKIE_SECRET=8OWtwSuCFOaqqapSYfqZSg\nexport SUPERADMIN_USERNAME=@@{vendure.username}@@\nexport SUPERADMIN_PASSWORD=@@{vendure.secret}@@\nexport DB_HOST=@@{vendure_db.address}@@\nexport DB_PORT=5432\nexport DB_NAME=vendure\nexport DB_USERNAME=@@{pg.username}@@\nexport DB_PASSWORD=@@{pg.secret}@@\nexport DB_SCHEMA=public\n\ncd @@{APP_DATA_DISK_MOUNTPOINT}@@\necho \"y\" | npx @vendure\/create my-shop --ci\n\ncd my-shop\nsudo npm install -g pm2\nnpm run build\n","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"afe5881e_dag_cloned_1","kind":"app_task"},"variable_list":[]},"uninstall_runbook":{"name":"bc5b8df7_runbook_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"d6e8deba_dag_cloned_1","description":"","attrs":{"type":"","edges":[{"type":"","from_task_reference":{"name":"SatelliteUnregister1","kind":"app_task"},"to_task_reference":{"name":"UnjoinDomain1","kind":"app_task"},"edge_type":"user_defined"}]},"child_tasks_local_reference_list":[{"name":"SatelliteUnregister1","kind":"app_task"},{"name":"UnjoinDomain1","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"Package1_cloned_0","kind":"app_package"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"SatelliteUnregister1","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n# region headers\n# * author:     haikel.zein@nutanix.com\n# task_name:    RegisterSatellite\n# description:  RegisterSatellite for RHEL 8   \n# output vars:  none\n# dependencies: none\n# endregion\n\necho \"Satellite Registration\"\nPATH=$PATH:\/bin:\/usr\/bin\nMYDIR=`dirname ${0}`\n\necho \"beginning vendor unregistration\"\nsudo subscription-manager unregister","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"UnjoinDomain1","description":"","attrs":{"type":"","script":"#leave domain\necho \"@@{active_directory.secret}@@\" | sudo realm leave --remove -U @@{active_directory.username}@@ @@{AD_DOMAIN}@@","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_app","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"d6e8deba_dag_cloned_1","kind":"app_task"},"variable_list":[]},"upgrade_runbook":{}}},{"type":"DEB","name":"Package1_cloned_0_cloned_0","description":"","variable_list":[],"action_list":[],"service_local_reference_list":[{"name":"vendure_web","kind":"app_service"}],"version":"","options":{"type":"","install_runbook":{"name":"d6329946_runbook_cloned_0_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"afe5881e_dag_cloned_1_cloned_1","description":"","attrs":{"type":"","edges":[{"type":"","from_task_reference":{"name":"MountNgt2","kind":"app_task"},"to_task_reference":{"name":"InstallNgt2","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InitDataDisk","kind":"app_task"},"to_task_reference":{"name":"InstallPodman2","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"DisableSeLinux2","kind":"app_task"},"to_task_reference":{"name":"EjectCdrom2","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"EjectCdrom2","kind":"app_task"},"to_task_reference":{"name":"VmRestart2","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"VmRestart2","kind":"app_task"},"to_task_reference":{"name":"SatelliteRegister2","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"SatelliteRegister2","kind":"app_task"},"to_task_reference":{"name":"YumCleanAndInstallPackages2","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"YumCleanAndInstallPackages2","kind":"app_task"},"to_task_reference":{"name":"InitDataDisk","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InstallPodman2","kind":"app_task"},"to_task_reference":{"name":"JoinDomain2","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"JoinDomain2","kind":"app_task"},"to_task_reference":{"name":"MountNgt2","kind":"app_task"},"edge_type":"user_defined"},{"type":"","from_task_reference":{"name":"InstallNgt2","kind":"app_task"},"to_task_reference":{"name":"InstallFrontend","kind":"app_task"},"edge_type":"user_defined"}]},"child_tasks_local_reference_list":[{"name":"MountNgt2","kind":"app_task"},{"name":"InstallNgt2","kind":"app_task"},{"name":"SatelliteRegister2","kind":"app_task"},{"name":"DisableSeLinux2","kind":"app_task"},{"name":"YumCleanAndInstallPackages2","kind":"app_task"},{"name":"EjectCdrom2","kind":"app_task"},{"name":"InstallPodman2","kind":"app_task"},{"name":"JoinDomain2","kind":"app_task"},{"name":"InitDataDisk","kind":"app_task"},{"name":"VmRestart2","kind":"app_task"},{"name":"InstallFrontend","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"Package1_cloned_0_cloned_0","kind":"app_package"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"MountNgt2","description":"","attrs":{"type":"","script":"#!\/usr\/bin\/python\n################################################\n########     http_requests.py           ########\n################################################\n# import json #tocomment\n# from time import sleep #tocomment\n\nimport requests\n\n\n# For token-based authentication, omit user and password (so that they default to None), and add the following header to\n# the headers list: 'Authorization': 'Bearer <token value>'\ndef process_request(url, method, user=None, password=None, cert=None, files=None,headers=None, payload=None, params=None, secure=False, timeout=120, retries=5, exit_on_failure=True):\n    \"\"\"\n    Processes a web request and handles result appropriately with retries.\n    Returns the content of the web request if successfull.\n    \"\"\"\n    if payload is not None:\n        payload = json.dumps(payload)\n\n    sleep_between_retries=5\n    \n    while retries > 0:\n        try:\n\n            if method == 'GET':\n                response = requests.get(\n                    url,\n                    headers=headers,\n                    auth=(user, password) if user else None,\n                    cert=cert if cert else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'POST':\n                response = requests.post(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'PUT':\n                response = requests.put(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    files=files if files else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'PATCH':\n                response = requests.patch(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n            elif method == 'DELETE':\n                response = requests.delete(\n                    url,\n                    headers=headers,\n                    data=payload,\n                    auth=(user, password) if user else None,\n                    params=params,\n                    verify=secure,\n                    timeout=timeout\n                )\n\n        except requests.exceptions.RequestException as error_code:\n            print('Error: {c}, Message: {m}'.format(c = type(error_code).__name__, m = str(error_code)))\n            retries -= 1\n            sleep(sleep_between_retries)\n            continue\n        \n        if response.ok:\n            return response\n        elif response.status_code == 409:\n            print(response.text)\n            retries -= 1\n            if retries == 0:\n                if exit_on_failure:\n                    exit(response.status_code)\n                else:\n                    return response\n            sleep(sleep_between_retries)\n            continue\n        else:\n            print(response.text)\n            if exit_on_failure:\n                exit(response.status_code)\n            else:\n                return response\n\n\n################################################\n############ pc_tasks.py            ############\n################################################\n\n############# Calm imports #################################################################\n# CALM_USES http_requests.py\n############################################################################################\n# from  http_requests import * #tocomment\n# from time import sleep  #tocomment\n\ndef prism_monitor_task_apiv3(api_server,username,passwd,task_uuid,secure=False,exit_on_task_failure=True):\n\n    \"\"\"Given a Prism Central task uuid, loop until the task is completed\n    exits if the task fails\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        task_uuid: Prism Central task uuid (generally returned by another action \n                   performed on PC).\n        secure: boolean to verify or not the api server's certificate (True\/False)\n                   \n    Returns:\n        No value is returned\n    \"\"\"\n    \n    task_status_details = {}\n    task_status = \"RUNNING\"\n\n    headers = {\n    'Content-Type': 'application\/json',\n    'Accept': 'application\/json'\n    }\n    api_server_port = \"9440\"\n    api_server_endpoint = \"\/api\/nutanix\/v3\/tasks\/{0}\".format(task_uuid)\n    url = \"https:\/\/{}:{}{}\".format(\n        api_server,\n        api_server_port,\n        api_server_endpoint\n    )\n    method = \"GET\"\n    print(\"Making a {} API call to {}\".format(method, url))\n    \n    while True:\n        resp = process_request(url,method,user=username,password=passwd,headers=headers,secure=secure)\n        #print(json.loads(resp.content))\n        if resp.ok:\n            task_status_details = json.loads(resp.content)\n            task_status = resp.json()['status']\n            if task_status == \"SUCCEEDED\":\n                print (\"Task has completed successfully\")\n                return task_status_details\n            elif task_status == \"FAILED\":\n                print (\"Task has failed: {}\".format(   resp.json()['error_detail'] if 'error_detail' in resp.json() else \"No Info\" )       )\n                if exit_on_task_failure:\n                    exit(1)\n                else:\n                    return task_status_details\n            else:\n                print (\"Task status is {} and percentage completion is {}. Current step is {}. Waiting for 30 seconds.\".format(task_status,resp.json()['percentage_complete'],resp.json()['progress_message']))\n                sleep(30)\n        else:\n            print(\"Request failed!\")\n            print(\"status code: {}\".format(resp.status_code))\n            print(\"reason: {}\".format(resp.reason))\n            print(\"text: {}\".format(resp.text))\n            print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n            print(\"elapsed: {}\".format(resp.elapsed))\n            print(\"headers: {}\".format(resp.headers))\n            print(json.dumps(\n                json.loads(resp.content),\n                indent=4\n            ))\n            exit(resp.status_code)\n\n    return task_status_details\n\n\ndef monitor_multiple_tasks_apiv3(api_server,username,passwd,task_uuid_list, nb_retries=120, wait_interval=30, secure=False):\n\n    \"\"\"Given a Prism Central list of tasks uuids, loop until all tasks finish or some task fails\n    exits if the one of the tasks fails\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        task_uuid_list: comma-separated list of tasks uuids\n        nb_retries: number of retires before timeout\n        wait_interval: interval between retries in seconds\n        secure: boolean to verify or not the api server's certificate (True\/False)\n\n    Returns:\n        No value is returned\n    \"\"\"\n\n    if task_uuid_list == \"\":\n        return\n    for x in range(nb_retries):\n        tasks_status_list = []\n        for task_uuid in task_uuid_list.split(','):\n            headers = {\n                'Content-Type': 'application\/json',\n                'Accept': 'application\/json'\n            }\n            api_server_port = \"9440\"\n            api_server_endpoint = \"\/api\/nutanix\/v3\/tasks\/{0}\".format(task_uuid)\n            url = \"https:\/\/{}:{}{}\".format(\n                api_server,\n                api_server_port,\n                api_server_endpoint\n            )\n            method = \"GET\"\n            resp = process_request(url=url,method=method,user=username,password=passwd,headers=headers,secure=secure)\n            if resp.ok:\n                task_status_details = json.loads(resp.content)\n                task_status = resp.json()['status']\n            else:\n                print(\"ERROR - Failed to fetch task {} \".format(task_uuid))\n                task_status_details = None\n                task_status = \"Fetch Failed\"\n\n            tasks_status_list.append(\n                {\n                    \"uuid\": task_uuid,\n                    \"state\": task_status,\n                    \"details\" : task_status_details\n                }\n            )\n\n        print(\">>>>> current tasks status:\")\n        overall_state = \"SUCCEEDED\"\n        for task_status in tasks_status_list:\n            print(\"Task UUID : {} \\n\\tStatus :{}\".format(task_status[\"uuid\"],task_status.get(\"state\")))\n            if task_status[\"state\"].upper() == \"FETCH FAILED\":\n                overall_state = \"FAILED\"                \n                print(\"Could not Fetch the Task Status Details \")\n            elif task_status[\"state\"].upper() == \"FAILED\":\n                overall_state = \"FAILED\"\n                print(\"\\tReason for failure : {}\".format(task_status[\"details\"][\"error_detail\"] if 'error_detail' in task_status[\"details\"] else \"No Info\"))\n                print(\"Complete response : {} \".format(task_status[\"details\"]))\n            elif task_status[\"state\"].upper() != \"SUCCEEDED\" and overall_state != \"FAILED\":\n                overall_state = \"inprogress\"\n            for i in range(20): print(\"-\")\n        \n        if overall_state == \"FAILED\":\n            print(\"ERROR - Some Tasks failed. Refer above for the error details\")\n            exit(1)\n        elif overall_state == \"SUCCEEDED\":\n            print(\"INFO - All tasks finished Successfully.\")\n            return\n        else:\n            print(\"INFO - Tasks are still in progress, waiting...\")\n            sleep(wait_interval)\n    #here the monitoring times out\n    print(\"ERROR - Tasks monitoring timed out\")\n    exit(1)\n\n\n\n\n########################################################################\n############       pc_entities.py                           ############\n########################################################################\n# CALM_USES http_requests.py\n# from  http_requests import * #tocomment\n\ndef prism_get_entities(api_server,username,passwd,entity_type,entity_api_root,secure=False,print_f=True,filter=None):\n\n    \"\"\"Retrieve the list of entities from Prism Central.\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        entity_type: kind (type) of entity as referenced in the entity json object\n        entity_api_root: v3 apis root for this entity type. for example. for projects the list api is \"...\/api\/nutanix\/v3\/projects\/list\".\n                         the entity api root here is \"projects\"\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        filter: filter to be applied to the search\n        \n    Returns:\n        An array of entities (entities part of the json response).\n    \"\"\"\n\n    entities = []\n    #region prepare the api call\n    headers = {\n        'Content-Type': 'application\/json',\n        'Accept': 'application\/json'\n    }\n    api_server_port = \"9440\"\n    api_server_endpoint = \"\/api\/nutanix\/v3\/{}\/list\".format(entity_api_root)\n    url = \"https:\/\/{}:{}{}\".format(\n        api_server,\n        api_server_port,\n        api_server_endpoint\n    )\n    method = \"POST\"\n    length = 100\n\n    # Compose the json payload\n    payload = {\n        \"kind\": entity_type,\n        \"offset\": 0,\n        \"length\": length\n    }\n    if filter:\n        payload[\"filter\"] = filter\n    #endregion\n    while True:\n        if print_f:\n            print(\"Making a {} API call to {} with secure set to {}\".format(method, url, secure))\n        resp = process_request(url,method,user=username,password=passwd,headers=headers,payload=payload,secure=secure)\n        # deal with the result\/response\n        if resp.ok:\n            json_resp = json.loads(resp.content)\n            #json_resp = resp\n            entities.extend(json_resp['entities'])\n            key = 'length'\n            if key in json_resp['metadata']:\n                if json_resp['metadata']['length'] == length:\n                    if print_f:\n                        print(\"Processing results from {} to {} out of {}\".format(\n                            json_resp['metadata']['offset'], \n                            json_resp['metadata']['length']+json_resp['metadata']['offset'],\n                            json_resp['metadata']['total_matches']))\n                    payload = {\n                        \"kind\": entity_type,\n                        \"offset\": json_resp['metadata']['length'] + json_resp['metadata']['offset'] + 1,\n                        \"length\": length\n                    }\n                else:\n                    return entities\n            else:\n                return entities\n        else:\n            print(\"Request failed!\")\n            print(\"status code: {}\".format(resp.status_code))\n            print(\"reason: {}\".format(resp.reason))\n            print(\"text: {}\".format(resp.text))\n            print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n            print(\"elapsed: {}\".format(resp.elapsed))\n            print(\"headers: {}\".format(resp.headers))\n            print(\"payload: {}\".format(payload))\n            print(json.dumps(\n                json.loads(resp.content),\n                indent=4\n            ))\n            raise\n\n\ndef prism_get_entity(api_server,username,passwd,entity_type,entity_api_root,entity_name=None,entity_uuid=None,secure=False,print_f=True):\n\n    \"\"\"Returns from Prism Central the uuid and details of a given entity name.\n       If an entity_uuid is specified, it will skip retrieving all entities by specifying the uuid in the arguments (faster).\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        entity_type: kind (type) of entity as referenced in the entity json object\n        entity_api_root: v3 apis root for this entity type. for example. for projects the list api is \"...\/api\/nutanix\/v3\/projects\/list\".\n                         the entity api root here is \"projects\"\n        entity_name: Name of the entity (optional).\n        entity_uuid: Uuid of the entity (optional).\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    Returns:\n        A string containing the UUID of the entity (entity_uuid) and the json content\n        of the entity details (entity_details)\n    \"\"\"\n    \n    entity_details = {}\n\n    if entity_uuid is None:\n        #get the entities list from Prism\n        entity_list = prism_get_entities(api_server=api_server,username=username,passwd=passwd,\n                                          entity_type=entity_type,entity_api_root=entity_api_root,\n                                          secure=secure,print_f=print_f)\n        entity_obj_list = [ entity for entity in entity_list if entity['status']['name'] == entity_name ] \n        if len(entity_obj_list) !=1:\n            print(\"ERROR - found {} instance(s) of the entity {}\".format(len(entity_obj_list),entity_name))\n            exit(1)\n\n        for entity in entity_list:\n            fetched_name = \"\"\n            if \"name\" in entity['spec']:\n                fetched_name = entity['spec']['name']\n            elif \"name\" in entity['status']:\n                fetched_name = entity['status']['name']\n            else:\n                print(\"ERROR - fetched entity name could not be extracted for entity {}\".format(entity['metadata']['uuid']))\n                raise\n            if fetched_name == entity_name:\n                entity_uuid = entity['metadata']['uuid']\n                entity_details = entity.copy()\n                break\n        if entity_details == {} :\n            print(\"ERROR - Entity {} not found\".format(entity_name))\n            exit(1)\n    else:\n        headers = {\n            'Content-Type': 'application\/json',\n            'Accept': 'application\/json'\n        }\n        api_server_port = \"9440\"\n        api_server_endpoint = \"\/api\/nutanix\/v3\/{}\/{}\".format(entity_api_root,entity_uuid)\n        url = \"https:\/\/{}:{}{}\".format(\n            api_server,\n            api_server_port,\n            api_server_endpoint\n        )\n        method = \"GET\"\n        if print_f:\n            print(\"Making a {} API call to {} with secure set to {}\".format(method, url, secure))\n        resp = process_request(url=url,method=method,user=username,password=passwd,headers=headers,secure=secure)\n        if resp.ok:\n            entity_details = json.loads(resp.content)\n        else:\n            print(\"Request failed!\")\n            print(\"status code: {}\".format(resp.status_code))\n            print(\"reason: {}\".format(resp.reason))\n            print(\"text: {}\".format(resp.text))\n            print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n            print(\"elapsed: {}\".format(resp.elapsed))\n            print(\"headers: {}\".format(resp.headers))\n            print(\"payload: {}\".format(payload))\n            print(json.dumps(\n                json.loads(resp.content),\n                indent=4\n            ))\n            raise\n    return entity_uuid, entity_details\n\n\ndef prism_get_entity_uuid(api_server,username,passwd,entity_type,entity_api_root,entity_name=None,secure=False,print_f=True):\n\n    \"\"\"Returns from Prism Central the uuid of a given entity name.\n       \n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        entity_type: kind (type) of entity as referenced in the entity json object\n        entity_api_root: v3 apis root for this entity type. for example. for projects the list api is \"...\/api\/nutanix\/v3\/projects\/list\".\n                         the entity api root here is \"projects\"\n        entity_name: Name of the entity \n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    Returns:\n        A string containing the UUID of the entity (entity_uuid) and the json content\n        of the entity details (entity_details)\n    \"\"\"\n    \n    #get the entities list from Prism\n    entity_list = prism_get_entities(api_server=api_server,username=username,passwd=passwd,\n                                        entity_type=entity_type,entity_api_root=entity_api_root,\n                                        secure=secure,print_f=print_f)\n    entity_uuid = None\n    for entity in entity_list:\n        fetched_name = \"\"\n        if \"name\" in entity['spec']:\n            fetched_name = entity['spec']['name']\n        elif \"name\" in entity['status']:\n            fetched_name = entity['status']['name']\n        else:\n            print(\"ERROR - fetched entity name could not be extracted for entity {}\".format(entity['metadata']['uuid']))\n            raise\n        if fetched_name == entity_name:\n            entity_uuid = entity['metadata']['uuid']\n            break\n    if entity_uuid is None:\n        print(\"Error: Enitity ID could not be retrieved for entity '{}' of kind '{}'\".format(entity_name,entity_type))\n        raise\n    return entity_uuid\n\n\n\n################################################\n############     pc_vm.py          ############\n################################################\n\n############# Calm imports #################################################################\n# CALM_USES pc_entities.py, pc_tasks.py\n############################################################################################\n# from pc_entities import * #tocomment\n# from pc_tasks import * #tocomment\n\nIB_HEADERS = {\n        'Content-Type': 'application\/json',\n        'Accept': 'application\/json'\n    }\n\n\ndef prism_get_vm(api_server,username,passwd,vm_name=None,vm_uuid=None,secure=False,print_f=True):\n    \n    \"\"\"Returns from Prism Central the uuid and details of a given vm name.\n       If a vm_uuid is specified, it will skip retrieving all vms (faster).\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        vm_name: Name of the vm(optional).\n        vm_uuid: Uuid of the vm (optional).\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    Returns:\n        A string containing the UUID of the vm (vm_uuid) and the json content\n        of the vm details (vm_details)\n    \"\"\"\n\n    vm_uuid, vm = prism_get_entity(api_server=api_server,username=username,passwd=passwd,\n                                             entity_type=\"vm\",entity_api_root=\"vms\",entity_name=vm_name,entity_uuid=vm_uuid,\n                                             secure=secure,print_f=print_f)\n    return vm_uuid, vm\n\n\ndef prism_put_vm(api_server,username,passwd,vm_uuid,payload,secure=False):\n    headers = {\n        'Content-Type': 'application\/json',\n        'Accept': 'application\/json'\n    }\n    api_server_port = \"9440\"\n    api_server_endpoint = \"\/api\/nutanix\/v3\/vms\/{}\".format(vm_uuid)\n    url = \"https:\/\/{}:{}{}\".format(\n        api_server,\n        api_server_port,\n        api_server_endpoint\n    )\n    method = \"PUT\"\n    #print(\" VM API PUT call '{}' with payload '{}' \".format(url,payload))\n    resp = process_request(url=url,method=method,user=username,password=passwd,headers=headers,payload=payload,secure=secure)\n    task_uuid = None \n    if resp.ok:\n        print(\"INFO - API PUT call initiated with success for VM : '{}'\".format(vm_uuid))\n        res = json.loads(resp.content)\n        if \"status\" in res and \"execution_context\" in res[\"status\"] \\\n                    and \"task_uuid\" in res[\"status\"][\"execution_context\"]:\n            task_uuid = res[\"status\"][\"execution_context\"][\"task_uuid\"]\n            task_status_details = prism_monitor_task_apiv3(api_server=api_server,username=username,passwd=passwd,secure=secure,task_uuid=task_uuid)\n            return resp, task_status_details\n    elif resp.status_code == 409:\n        return resp, False \n    else:\n        print(\"Request failed!\")\n        print(\"status code: {}\".format(resp.status_code))\n        print(\"reason: {}\".format(resp.reason))\n        print(\"text: {}\".format(resp.text))\n        print(\"raise_for_status: {}\".format(resp.raise_for_status()))\n        print(\"elapsed: {}\".format(resp.elapsed))\n        print(\"headers: {}\".format(resp.headers))\n        print(\"payload: {}\".format(payload))\n        print(json.dumps(\n            json.loads(resp.content),\n            indent=4\n        ))\n        return resp , False \n\n\n\n\ndef prism_mount_enable_ngt_on_vm(api_server,username,passwd,vm_uuid=None,vm_name=None,secure=False,print_f=True):\n    \n    \"\"\"Function to mount and enable NGT on VM\n\n    Args:\n        api_server: The IP or FQDN of Prism.\n        username: The Prism user name.\n        secret: The Prism user name password.\n        vm_name: Name of the vm(optional).\n        vm_uuid: Uuid of the vm (optional).\n        secure: boolean to verify or not the api server's certificate (True\/False) \n        print_f: True\/False. if False the function does not print traces to the stdout, as long as there are no errors\n        \n    \"\"\"\n    vm_uuid, payload = prism_get_vm(api_server=api_server,username=username,passwd=passwd,vm_uuid=vm_uuid)\n    del payload['status']\n    payload[\"spec\"][\"resources\"].update(\n        {\n            \"guest_tools\": {\n                \"nutanix_guest_tools\": {\n                    \"iso_mount_state\": \"MOUNTED\",\n                    \"state\": \"ENABLED\",\n                    \"enabled_capability_list\": [\"SELF_SERVICE_RESTORE\",\"VSS_SNAPSHOT\"]\n                }\n            }\n        }\n    )\n    resp, task_status_details = prism_put_vm(api_server=api_server,username=username,passwd=passwd,vm_uuid=vm_uuid,payload=payload)\n    return resp, task_status_details\n\n\n\n############# Calm imports #################################################################\n# CALM_USES pc_vm.py\n############################################################################################\n\n### Below lines used for Cyberark cred retrieval ####\n\nPC_PROVIDER_USERNAME = \"@@{prism_central.username}@@\"\nPC_PROVIDER_PASSWD = \"@@{prism_central.secret}@@\"\nPC_PROVIDER_SECURE = False\nPC_PROVIDER_ADDRESS = \"@@{PC_API_FQDN}@@\"\nNGT_INSTALL = \"@@{NGT_INSTALL}@@\"\n\n# region capture Calm macros\nif NGT_INSTALL == \"Yes\":\n    vm_uuid = \"@@{platform.metadata.uuid}@@\"\n    sleep(20)   ############buffer time for VM provision\/ power on\/off ##############\n    prism_mount_enable_ngt_on_vm(api_server=PC_PROVIDER_ADDRESS,username=PC_PROVIDER_USERNAME,passwd=PC_PROVIDER_PASSWD,vm_uuid=vm_uuid)\n    sleep(20)   ############buffer time for VM provision\/ power on\/off ##############","script_type":"static_py3","command_line_args":"","exit_status":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InstallNgt2","description":"","attrs":{"type":"","script":"NGT_INSTALL=\"@@{NGT_INSTALL}@@\"\nif [ $NGT_INSTALL = \"Yes\" ]; then\n\tsudo mkdir -p \/tmp\/ngt\n\tmountpt=`sudo blkid | grep -i nutanix | cut -d ':' -f1`\n\tsudo mount $mountpt \/tmp\/ngt\n\techo \"Mount point is $mountpt\"\n\tsudo \/bin\/sh \/tmp\/ngt\/installer\/linux\/install_ngt.sh -o install\n\tsleep 10\n\tsudo umount \/tmp\/ngt\n\texit 0\nfi","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"SatelliteRegister2","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n# region headers\n# * author:     haikel.zein@nutanix.com\n# task_name:    RegisterSatellite\n# description:  RegisterSatellite for RHEL 8   \n# updated:\t    20250129\n# description:\tadded error handling and retry logic\n# updated by:   dz@nutanix.com\n# output vars:  none\n# dependencies: none\n# endregion\n\necho \"Satellite Registration\"\nPATH=$PATH:\/bin:\/usr\/bin\nMAX_RETRIES=6\nRETRY_DELAY=10\n\necho \"Beginning vendor registration\"\nfor ((i=1; i<=MAX_RETRIES; i++)); do\n\tif sudo subscription-manager register --username @@{redhat.username}@@ --password @@{redhat.secret}@@ --auto-attach --force; then\n      echo \"Registration successful\"\n      break\n    else\n      echo \"Error: Registration failed with HTTP error code 500: Internal Server Error. Retry $i\/$MAX_RETRIES.\"\n      if [ $i -eq $MAX_RETRIES ]; then\n        echo \"Maximum retries reached. Exiting...\"\n        exit 1\n      fi\n      sleep $RETRY_DELAY\n    fi\n done","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"DisableSeLinux2","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n\n# region headers\n# * author:     stephane.bourdeaud@nutanix.com\n# * version:    v1.0\/20210504 - cita-starter version\n# task_name:    DisableSelinux\n# description:  disables enforcement of selinux policy.               \n# output vars:  none\n# dependencies: none\n# endregion\n\nsudo hostnamectl set-hostname --static @@{name}@@\necho \"@@{address}@@  @@{name}@@\" | sudo tee -a \/etc\/hosts\n\n#sudo \/bin\/systemctl stop firewalld || true\n#sudo \/bin\/systemctl disable firewalld || true\n\nsudo sed -i 's\/SELINUX=enforcing\/SELINUX=disabled\/' \/etc\/selinux\/config\nsudo setenforce 0","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"YumCleanAndInstallPackages2","description":"","attrs":{"type":"","script":"# this is required or update will fail on filesystem package\nsudo umount \/mnt\n\n# run yum clean\nsudo yum clean all -y\n\n# run yum install lvm2 - required for NGT\nsudo yum install lvm2 jq fio python3 stress-ng -y -q\n\n# set python\nsudo alternatives --set python \/usr\/bin\/python3\npython --version","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"EjectCdrom2","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n\n# region headers\n# * author:     stephane.bourdeaud@nutanix.com\n# * version:    v1.0\/20210504 - cita-starter version\n# task_name:    EjectCdrom\n# description:  ejects all cdrom devices (\/dev\/sr*).               \n# output vars:  none\n# dependencies: none\n# endregion\n\nfor device in \/dev\/sr*\ndo \n    sudo eject $device\n    echo \"Ejected ${device}\"\ndone","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InstallPodman2","description":"","attrs":{"type":"","script":"sudo dnf install -y podman\npython -m ensurepip --upgrade\npython -m pip install podman-compose\npodman login --username @@{docker.username}@@ --password @@{docker.secret}@@ docker.io\nsudo usermod --add-subuids 100000-165535 @@{cred_linux.username}@@\nsudo usermod --add-subgids 100000-165535 @@{cred_linux.username}@@\nloginctl enable-linger\n","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"JoinDomain2","description":"","attrs":{"type":"","script":"#install pre-reqs\nsudo dnf install -y realmd sssd oddjob oddjob-mkhomedir adcli samba-common-tools krb5-workstation\n\n#join domain\nsudo hostnamectl set-hostname @@{name}@@.@@{DOMAIN}@@\nsudo realm discover @@{AD_DOMAIN}@@\necho \"@@{active_directory.secret}@@\" | sudo realm join @@{AD_DOMAIN}@@ --computer-ou=\"@@{AD_OU_PATH}@@\" -U @@{active_directory.username}@@\n\n#enable ddns\necho \"dyndns_update = True\" | sudo tee -a \/etc\/sssd\/sssd.conf\necho \"dyndns_update_ptr = True\" | sudo tee -a \/etc\/sssd\/sssd.conf\necho \"dyndns_refresh_interval = 3600\" | sudo tee -a \/etc\/sssd\/sssd.conf\necho \"dyndns_ttl = 300\" | sudo tee -a \/etc\/sssd\/sssd.conf\nsudo rm -f \/var\/lib\/sss\/db\/*\nsudo systemctl restart sssd","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InitDataDisk","description":"","attrs":{"type":"","script":"# region headers\n# * author:     stephane.bourdeaud@nutanix.com\n# * version:    v1.0\/20230516 - rhel 8 version\n# task_name:    InitializeDataDisk\n# description:  configured \/dev\/sdb1 as an lvm volume, formats it\n#               as ext4 and mounts it in the specified mountpoint, \n#               also configuring fstab.               \n# output vars:  none\n# dependencies: none\n# endregion\n\n#sudo yum install -y lvm2 jq\nfree_device=$(lsblk --json | jq -r '.blockdevices[] | select(.type == \"disk\" and (.children | length == 0 or not .children?)) | .name' | while read DISK_NAME; do echo \"\/dev\/$DISK_NAME\"; done)\nfree_partition=\"${free_device}1\"\nprintf 'o\\nn\\np\\n\\n\\n\\nt\\n8e\\nw' | sudo fdisk $free_device\nsudo pvcreate $free_partition\nsudo vgcreate vg0 $free_partition\nsudo lvcreate -n data -l 100%FREE vg0\nsudo mkfs.ext4 \/dev\/vg0\/data\nsudo mkdir -p @@{WEB_DATA_DISK_MOUNTPOINT}@@\nsudo mount \/dev\/vg0\/data @@{WEB_DATA_DISK_MOUNTPOINT}@@\necho '\/dev\/mapper\/vg0-data @@{WEB_DATA_DISK_MOUNTPOINT}@@ ext4 defaults 0 0' | sudo tee -a \/etc\/fstab\nsudo chown -R @@{cred_linux.username}@@:@@{cred_linux.username}@@ @@{WEB_DATA_DISK_MOUNTPOINT}@@\nsudo chmod -R 755 @@{WEB_DATA_DISK_MOUNTPOINT}@@","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"CALL_RUNBOOK","name":"VmRestart2","description":"","attrs":{"type":"CALL_RUNBOOK","runbook_reference":{"name":"SYS_GEN__substrate__web_frontend__action_restart__runbook","kind":"app_runbook"},"inarg_list":[]},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"InstallFrontend","description":"","attrs":{"type":"","script":"sudo dnf install -y git\ncd @@{WEB_DATA_DISK_MOUNTPOINT}@@\ngit clone https:\/\/github.com\/vendure-ecommerce\/storefront-angular-starter.git\ncd storefront-angular-starter\n\nsed -i \"s|https:\/\/readonlydemo.vendure.io|http:\/\/@@{vendure_app.address}@@|g\" .\/src\/environments\/environment.prod.ts\nsed -i \"\/apiPort:\/s\/443\/3000\/g\" .\/src\/environments\/environment.prod.ts\n\nsudo dnf module enable nodejs:20 -y\nsudo dnf install nodejs -y\nsudo npm install -g pm2\n\nnpm install --legacy-peer-deps\necho \"y\" | npm run build:ssr\n\npm2 start npm -- start\npm2 start dist\/server\/main.js --name \"frontend\"","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"afe5881e_dag_cloned_1_cloned_1","kind":"app_task"},"variable_list":[]},"uninstall_runbook":{"name":"bc5b8df7_runbook_cloned_0_cloned_0","description":"","task_definition_list":[{"type":"DAG","name":"d6e8deba_dag_cloned_1_cloned_1","description":"","attrs":{"type":"","edges":[{"type":"","from_task_reference":{"name":"SatelliteUnregister_cloned_1_cloned_1","kind":"app_task"},"to_task_reference":{"name":"UnjoinDomain_cloned_1_cloned_1","kind":"app_task"},"edge_type":"user_defined"}]},"child_tasks_local_reference_list":[{"name":"SatelliteUnregister_cloned_1_cloned_1","kind":"app_task"},{"name":"UnjoinDomain_cloned_1_cloned_1","kind":"app_task"}],"variable_list":[],"target_any_local_reference":{"name":"Package1_cloned_0_cloned_0","kind":"app_package"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"SatelliteUnregister_cloned_1_cloned_1","description":"","attrs":{"type":"","script":"#!\/bin\/bash\n# region headers\n# * author:     haikel.zein@nutanix.com\n# task_name:    RegisterSatellite\n# description:  RegisterSatellite for RHEL 8   \n# output vars:  none\n# dependencies: none\n# endregion\n\necho \"Satellite Registration\"\nPATH=$PATH:\/bin:\/usr\/bin\nMYDIR=`dirname ${0}`\n\necho \"beginning vendor unregistration\"\nsudo subscription-manager unregister","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]},{"type":"EXEC","name":"UnjoinDomain_cloned_1_cloned_1","description":"","attrs":{"type":"","script":"#leave domain\necho \"@@{active_directory.secret}@@\" | sudo realm leave --remove -U @@{active_directory.username}@@ @@{AD_DOMAIN}@@","script_type":"sh","command_line_args":"","exit_status":[],"login_credential_local_reference":{"name":"cred_linux","kind":"app_credential"}},"child_tasks_local_reference_list":[],"variable_list":[],"target_any_local_reference":{"name":"vendure_web","kind":"app_service"},"timeout_secs":"0","retries":"0","inherit_target":false,"status_map_list":[]}],"main_task_local_reference":{"name":"d6e8deba_dag_cloned_1_cloned_1","kind":"app_task"},"variable_list":[]},"upgrade_runbook":{}}}],"app_profile_list":[{"name":"Default","description":"","variable_list":[{"type":"LOCAL","name":"WEB_DATA_DISK_MOUNTPOINT","description":"","options":{"type":"PREDEFINED","choices":[]},"is_hidden":false,"is_mandatory":false,"data_type":"BASE","val_type":"STRING","label":"","attrs":{"type":""},"value":"\/mnt\/data"},{"type":"LOCAL","name":"DB_DATA_DISK_MOUNTPOINT","description":"","options":{"type":"PREDEFINED","choices":[]},"is_hidden":false,"is_mandatory":false,"data_type":"BASE","val_type":"STRING","label":"","attrs":{"type":""},"value":"\/home\/nutanix\/.local\/share\/containers\/storage"},{"type":"LOCAL","name":"APP_DATA_DISK_MOUNTPOINT","description":"","options":{"type":"PREDEFINED","choices":[]},"is_hidden":false,"is_mandatory":false,"data_type":"BASE","val_type":"STRING","label":"","attrs":{"type":""},"value":"\/mnt\/data"},{"type":"LOCAL","name":"OS_CRED_PUBLIC_KEY","description":"","options":{"type":"PREDEFINED","choices":[]},"is_hidden":false,"is_mandatory":false,"data_type":"BASE","val_type":"STRING","label":"","attrs":{"type":""},"value":"ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAACAQDf1v4t0K4zUETCQn8zD9oWF5mghOCb1mBPYTXank7dN1aOLuc24T9HCUlwYWrmZCHR32KEf352zkvGHVC\/PFkhhDU2rffRLl3nrx0CvYzYy6C9Xz4XgLh9nNlg75Us5LJA0vM4m92SabAvdm3mseVy5oeWdZ9vq0i7SDq1C\/rkinRydo4fqog1OodRW5wSOSF+sDPLuc7IyiISgilQW5C1jL738vIC2w4Yn5NJn+TpOu2QbSn19TgFaLiRx+4vNY92IOEcZsqQUcIXV0P9+OYjOimXt\/IxazSaPPj8G+qQ0C99XXdtFlh95c5ZNHvHz\/GbgzFH3ZXoGPRG48VJHC78XfG3Wk9FMARFVw1FPLRfQhQq4VebRT197ntT3NEr0ipWQ+Ec\/ArCJhJii11XhuyS97clUyNUOf0ywvlxazt1MIF9anstQPd9j8bulRsyLqDyZOiV7fvhLZmFLqJan1ZGDzSnQGBv+TRHOKg4AUyFUyF3r1S8eKWcgZqOHtTauDsSR0pTJqFuIJUboRaatvj\/CuPFEF8cCukt37zYENjrL58XooqJZJmRnzDPNKGoEQKXuekvaMHDg1KNBt9i8g3bNpxvPjJZ3xVJKdViIRQBdFLyyr377+n76zdTfAohrsC0Rto+InbNVBAygBky5bWLTGIgW75I6daGxUvFVKjG7w=="},{"type":"LOCAL","name":"AD_DOMAIN","description":"","options":{"type":"PREDEFINED","choices":[]},"is_hidden":false,"is_mandatory":false,"data_type":"BASE","val_type":"STRING","label":"","attrs":{"type":""},"value":"NVD.LOCAL"},{"type":"LOCAL","name":"AD_OU_PATH","description":"","options":{"type":"PREDEFINED","choices":[]},"is_hidden":false,"is_mandatory":false,"data_type":"BASE","val_type":"STRING","label":"","attrs":{"type":""},"value":"OU=Lab Machines,DC=nvd,DC=local"},{"type":"LOCAL","name":"DOMAIN","description":"","options":{"type":"PREDEFINED","choices":[]},"is_hidden":false,"is_mandatory":false,"data_type":"BASE","val_type":"STRING","label":"","attrs":{"type":""},"value":"nvd.local"},{"type":"LOCAL","name":"SLA","description":"","options":{"type":"PREDEFINED","choices":["Gold","Silver","Bronze","None"]},"is_hidden":false,"is_mandatory":false,"data_type":"BASE","val_type":"STRING","label":"","attrs":{"type":"LOCAL"},"editables":{"value":true},"value":"Bronze"},{"type":"LOCAL","name":"NGT_INSTALL","description":"","regex":{"value":"^.*$","should_validate":false},"options":{"type":"PREDEFINED","choices":["Yes","No"]},"is_hidden":false,"is_mandatory":false,"data_type":"BASE","val_type":"STRING","label":"","attrs":{"type":"LOCAL"},"editables":{"value":true},"value":"Yes"}],"action_list":[],"deployment_create_list":[{"type":"GREENFIELD","name":"deployment_a256a657","description":"","variable_list":[],"action_list":[],"depends_on_list":[],"min_replicas":"1","max_replicas":"1","default_replicas":"1","package_local_reference_list":[{"name":"Package1","kind":"app_package"}],"substrate_local_reference":{"name":"db_backend","kind":"app_substrate"},"published_service_local_reference_list":[]},{"type":"GREENFIELD","name":"deployment_2befcf11","description":"","variable_list":[],"action_list":[],"depends_on_list":[],"min_replicas":"1","max_replicas":"1","default_replicas":"1","package_local_reference_list":[{"name":"Package1_cloned_0","kind":"app_package"}],"substrate_local_reference":{"name":"web_app","kind":"app_substrate"},"published_service_local_reference_list":[]},{"type":"GREENFIELD","name":"deployment_08abbffa","description":"","variable_list":[],"action_list":[],"depends_on_list":[],"min_replicas":"1","max_replicas":"1","default_replicas":"1","package_local_reference_list":[{"name":"Package1_cloned_0_cloned_0","kind":"app_package"}],"substrate_local_reference":{"name":"web_frontend","kind":"app_substrate"},"published_service_local_reference_list":[]}],"snapshot_config_list":[],"restore_config_list":[],"environment_reference_list":["c3be1599-b5b3-f452-a4ac-3fc71295456d"],"application_url":"","patch_list":[]}],"credential_definition_list":[{"type":"KEY","name":"cred_linux","description":"","username":"nutanix","secret":{"attrs":{"secret_reference":{},"is_secret_modified":false}},"cred_class":"static"},{"type":"PASSWORD","name":"prism_central","description":"","username":"sb@nvd.local","secret":{"attrs":{"secret_reference":{},"is_secret_modified":false}},"cred_class":"static"},{"type":"PASSWORD","name":"redhat","description":"","username":"srbourdeaud73","secret":{"attrs":{"secret_reference":{},"is_secret_modified":false}},"cred_class":"static"},{"type":"PASSWORD","name":"pg","description":"","username":"postgres","secret":{"attrs":{"secret_reference":{},"is_secret_modified":false}},"cred_class":"static"},{"type":"PASSWORD","name":"docker","description":"","username":"sbourdeaud","secret":{"attrs":{"secret_reference":{},"is_secret_modified":false}},"cred_class":"static"},{"type":"PASSWORD","name":"active_directory","description":"","username":"sb@NVD.LOCAL","secret":{"attrs":{"secret_reference":{},"is_secret_modified":false}},"cred_class":"static"},{"type":"PASSWORD","name":"vendure","description":"","username":"superadmin","secret":{"attrs":{"secret_reference":{},"is_secret_modified":false}},"cred_class":"static"}],"default_credential_local_reference":{"name":"cred_linux","kind":"app_credential"},"type":"USER","client_attrs":{"af0531f4-8ccf-6be9-020a-c35e286be16a":{"x":227,"y":466.5},"2a273097-e3b3-11c4-1b48-4ee949021648":{"x":231,"y":685.5},"ad4cd34d-b307-1204-2944-b67194f358c1":{"x":802,"y":686.5},"406b655d-12eb-746e-c3c3-c3d429f38a9e":{"x":662,"y":543.5},"deployment_a256a657":{"x":663,"y":377.5},"deployment_2befcf11":{"x":424,"y":271.5},"deployment_08abbffa":{"x":255,"y":486.5}}}},"api_version":"3.0","product_version":"4.2.0","metadata":{"last_update_time":"1752674222860103","creation_time":"1752155835074526","spec_version":76,"name":"vendure","kind":"blueprint"},"contains_secrets":false}

[nx-sbourdeaud]

This is related to the presence of "vm restart" tasks in the install package. When those are removed from the install package, the decompile works fine.