From 5cacd27aa67c6e889810105e8e863129f76c7b32 Mon Sep 17 00:00:00 2001 From: mwaykole Date: Fri, 28 Oct 2022 21:11:35 +0530 Subject: [PATCH 01/11] Add_ods_upgrade_cmd in ocm.py Signed-off-by: mwaykole --- utils/scripts/ocm/ocm.py | 76 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 76 insertions(+) diff --git a/utils/scripts/ocm/ocm.py b/utils/scripts/ocm/ocm.py index f911e42de..c2de3e3b0 100644 --- a/utils/scripts/ocm/ocm.py +++ b/utils/scripts/ocm/ocm.py @@ -74,6 +74,8 @@ def __init__(self, args={}): self.osd_major_version = args.get("osd_major_version") self.osd_latest_version_data = args.get("osd_latest_version_data") self.new_run = args.get("new_run") + self.upadte_ocm_channel_json = args.get("upadte_ocm_channel_json") + self.update_policies_json = args.get("update_policies_json") self.service_account_file = "create_gcp_sa_json.json" ocm_env = glob.glob(dir_path + "/../../../ocm.json.*") if ocm_env != []: @@ -1166,6 +1168,31 @@ def compare_with_old_version_file(self): log.info("File is updated to : {} ".format(old_data)) + def change_cluster_channel_group(self): + """update the channel using ocm cmd""" + cluster_id = self.get_osd_cluster_id() + run_change_channel_cmd = ( + "ocm patch /api/clusters_mgmt/v1/clusters/{}" + " --body {}".format(cluster_id, self.upadte_ocm_channel_json)) + log.info(run_change_channel_cmd) + ret = execute_command(run_change_channel_cmd) + if ret is None: + log.info("Failed to Update the channel") + return ret + + def update_ocm_policy(self): + """upadte cluster policy to schedule for upgrade osd""" + cluster_id = self.get_osd_cluster_id() + log.info(self.get_osd_cluster_id()) + schedule_cluster_upgrade = ( + "ocm post /api/clusters_mgmt/v1/clusters/{}/upgrade_policies" + " --body {}".format(cluster_id, self.update_policies_json)) + ret = execute_command(schedule_cluster_upgrade) + if ret is None: + log.info("Failed to Update the Upgrade Policy") + return ret + + if __name__ == "__main__": # Instance for OpenshiftClusterManager Class @@ -1186,6 +1213,55 @@ def compare_with_old_version_file(self): subparsers = parser.add_subparsers( title="Available sub commands", help="Available sub commands" ) + # Argument of update_ocm_channel + update_ocm_policy = subparsers.add_parser( + "update_ocm_policy", + help="Parser to get osd chnages in json file", + formatter_class=argparse.ArgumentDefaultsHelpFormatter, + ) + update_ocm_policy.add_argument( + "--update-policies-json", + help="pass the json file to update ocm policy", + action="store", + dest="update_policies_json", + required=True, + ) + update_ocm_policy.add_argument( + "--cluster-name", + help="osd cluster name", + action="store", + dest="cluster_name", + metavar="", + default="osd-qe-1", + ) + update_ocm_policy.set_defaults( + func=ocm_obj.update_ocm_policy + ) + + # Argument of update_ocm_channel + update_ocm_channel = subparsers.add_parser( + "update_ocm_channel", + help="Parser to get osd chnages in json file", + formatter_class=argparse.ArgumentDefaultsHelpFormatter, + ) + update_ocm_channel.add_argument( + "--update-ocm-channel-json", + help="pass json file to update ocm channel", + action="store", + dest="upadte_ocm_channel_json", + required=True, + ) + update_ocm_channel.add_argument( + "--cluster-name", + help="osd cluster name", + action="store", + dest="cluster_name", + metavar="", + default="osd-qe-1", + ) + update_ocm_channel.set_defaults( + func=ocm_obj.change_cluster_channel_group + ) # Argument parsers for get ods_latest version get_latest_osd_candidate_json = subparsers.add_parser( From 0a8001de456aed8c19fd4a2ec4f388597b941982 Mon Sep 17 00:00:00 2001 From: mwaykole Date: Fri, 28 Oct 2022 22:26:12 +0530 Subject: [PATCH 02/11] Add_ods_upgrade_cmd in ocm.py Signed-off-by: mwaykole --- utils/scripts/ocm/ocm.py | 26 +++++++++++++++++++++++++- 1 file changed, 25 insertions(+), 1 deletion(-) diff --git a/utils/scripts/ocm/ocm.py b/utils/scripts/ocm/ocm.py index c2de3e3b0..02fe6ff03 100644 --- a/utils/scripts/ocm/ocm.py +++ b/utils/scripts/ocm/ocm.py @@ -1,6 +1,7 @@ import os import argparse import re +import ast import subprocess import shutil import yaml @@ -1180,10 +1181,33 @@ def change_cluster_channel_group(self): log.info("Failed to Update the channel") return ret + def update_ocm_policy(self): """upadte cluster policy to schedule for upgrade osd""" cluster_id = self.get_osd_cluster_id() - log.info(self.get_osd_cluster_id()) + utc_time_cmd = ( + ''' oc debug node/"$(oc get nodes | awk 'FNR == 2 {print $1}')"\ + -- chroot /host date -d '+7 min' -u '+%Y-%m-%dT%H:%M:%SZ' ''') + + utc_time = execute_command(utc_time_cmd) + data = read_data_from_json(self.update_policies_json) + data["next_run"] = utc_time.replace("\n", "") + + if data["version"] == "latest": + get_latest_upgradte_version = ( + "ocm get cluster {} |" + " jq -r '.version.available_upgrades | values'".format( + cluster_id)) + latest_upgrade_version = execute_command( + get_latest_upgradte_version) + log.info("Version Available to Upgrade are ...{}".format( + latest_upgrade_version)) + latest_upgrade_version = ( + ast.literal_eval(latest_upgrade_version)[-1]) + + data["version"] = latest_upgrade_version + + write_data_in_json(self.update_policies_json, data) schedule_cluster_upgrade = ( "ocm post /api/clusters_mgmt/v1/clusters/{}/upgrade_policies" " --body {}".format(cluster_id, self.update_policies_json)) From d89a306e7a85d48d73327def238492c6eddee31f Mon Sep 17 00:00:00 2001 From: mwaykole Date: Mon, 31 Oct 2022 10:05:33 +0530 Subject: [PATCH 03/11] Add_ods_upgrade_cmd in ocm.py Signed-off-by: mwaykole --- utils/scripts/ocm/ocm.py | 30 +++++++++++++++--------------- 1 file changed, 15 insertions(+), 15 deletions(-) diff --git a/utils/scripts/ocm/ocm.py b/utils/scripts/ocm/ocm.py index 02fe6ff03..4a9914f04 100644 --- a/utils/scripts/ocm/ocm.py +++ b/utils/scripts/ocm/ocm.py @@ -75,7 +75,7 @@ def __init__(self, args={}): self.osd_major_version = args.get("osd_major_version") self.osd_latest_version_data = args.get("osd_latest_version_data") self.new_run = args.get("new_run") - self.upadte_ocm_channel_json = args.get("upadte_ocm_channel_json") + self.update_ocm_channel_json = args.get("update_ocm_channel_json") self.update_policies_json = args.get("update_policies_json") self.service_account_file = "create_gcp_sa_json.json" ocm_env = glob.glob(dir_path + "/../../../ocm.json.*") @@ -1174,7 +1174,7 @@ def change_cluster_channel_group(self): cluster_id = self.get_osd_cluster_id() run_change_channel_cmd = ( "ocm patch /api/clusters_mgmt/v1/clusters/{}" - " --body {}".format(cluster_id, self.upadte_ocm_channel_json)) + " --body {}".format(cluster_id, self.update_ocm_channel_json)) log.info(run_change_channel_cmd) ret = execute_command(run_change_channel_cmd) if ret is None: @@ -1183,7 +1183,7 @@ def change_cluster_channel_group(self): def update_ocm_policy(self): - """upadte cluster policy to schedule for upgrade osd""" + """update cluster policy to schedule for upgrade osd""" cluster_id = self.get_osd_cluster_id() utc_time_cmd = ( ''' oc debug node/"$(oc get nodes | awk 'FNR == 2 {print $1}')"\ @@ -1194,12 +1194,12 @@ def update_ocm_policy(self): data["next_run"] = utc_time.replace("\n", "") if data["version"] == "latest": - get_latest_upgradte_version = ( + get_latest_upgrade_version = ( "ocm get cluster {} |" " jq -r '.version.available_upgrades | values'".format( cluster_id)) latest_upgrade_version = execute_command( - get_latest_upgradte_version) + get_latest_upgrade_version) log.info("Version Available to Upgrade are ...{}".format( latest_upgrade_version)) latest_upgrade_version = ( @@ -1240,7 +1240,7 @@ def update_ocm_policy(self): # Argument of update_ocm_channel update_ocm_policy = subparsers.add_parser( "update_ocm_policy", - help="Parser to get osd chnages in json file", + help="Parser to get osd changes in json file", formatter_class=argparse.ArgumentDefaultsHelpFormatter, ) update_ocm_policy.add_argument( @@ -1256,7 +1256,7 @@ def update_ocm_policy(self): action="store", dest="cluster_name", metavar="", - default="osd-qe-1", + default="qeaisrhods-xyz", ) update_ocm_policy.set_defaults( func=ocm_obj.update_ocm_policy @@ -1265,14 +1265,14 @@ def update_ocm_policy(self): # Argument of update_ocm_channel update_ocm_channel = subparsers.add_parser( "update_ocm_channel", - help="Parser to get osd chnages in json file", + help="Parser to get osd changes in json file", formatter_class=argparse.ArgumentDefaultsHelpFormatter, ) update_ocm_channel.add_argument( "--update-ocm-channel-json", help="pass json file to update ocm channel", action="store", - dest="upadte_ocm_channel_json", + dest="update_ocm_channel_json", required=True, ) update_ocm_channel.add_argument( @@ -1281,7 +1281,7 @@ def update_ocm_policy(self): action="store", dest="cluster_name", metavar="", - default="osd-qe-1", + default="qeaisrhods-xyz", ) update_ocm_channel.set_defaults( func=ocm_obj.change_cluster_channel_group @@ -1290,7 +1290,7 @@ def update_ocm_policy(self): # Argument parsers for get ods_latest version get_latest_osd_candidate_json = subparsers.add_parser( "get_latest_osd_candidate_json", - help="Parser to get osd chnages in json file", + help="Parser to get osd changes in json file", formatter_class=argparse.ArgumentDefaultsHelpFormatter, ) get_latest_osd_candidate_json.add_argument( @@ -1654,7 +1654,7 @@ def update_ocm_policy(self): action="store", dest="cluster_name", metavar="", - default="osd-qe-1", + default="qeaisrhods-xyz", ) delete_cluster_parser.set_defaults(func=ocm_obj.delete_cluster) @@ -1683,7 +1683,7 @@ def update_ocm_policy(self): action="store", dest="cluster_name", metavar="", - default="osd-qe-1", + default="qeaisrhods-xyz", ) delete_idp_parser.set_defaults(func=ocm_obj.delete_idp) @@ -1703,7 +1703,7 @@ def update_ocm_policy(self): action="store", dest="cluster_name", metavar="", - default="osd-qe-1", + default="qeaisrhods-xyz", ) info_parser.set_defaults(func=ocm_obj.get_osd_cluster_info) @@ -1725,7 +1725,7 @@ def update_ocm_policy(self): action="store", dest="cluster_name", metavar="", - default="osd-qe-1", + default="qeaisrhods-xyz", ) optional_update_info_parser.add_argument( "--htpasswd-cluster-password", From de69b844fd1c6b11b954043f47e652e17636dede Mon Sep 17 00:00:00 2001 From: mwaykole Date: Mon, 31 Oct 2022 10:13:46 +0530 Subject: [PATCH 04/11] Add_ods_upgrade_cmd in ocm.py Signed-off-by: mwaykole --- utils/scripts/ocm/ocm.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/utils/scripts/ocm/ocm.py b/utils/scripts/ocm/ocm.py index 4a9914f04..4fc3951b3 100644 --- a/utils/scripts/ocm/ocm.py +++ b/utils/scripts/ocm/ocm.py @@ -1178,7 +1178,9 @@ def change_cluster_channel_group(self): log.info(run_change_channel_cmd) ret = execute_command(run_change_channel_cmd) if ret is None: - log.info("Failed to Update the channel") + log.info( + "Failed to update the channel to {}".format( + self.cluster_name)) return ret From 453f7441f93e31d288365b2983eec79c9bf1b181 Mon Sep 17 00:00:00 2001 From: mwaykole Date: Mon, 31 Oct 2022 14:13:48 +0530 Subject: [PATCH 05/11] Add_ods_upgrade_cmd in ocm.py Signed-off-by: mwaykole --- utils/scripts/ocm/ocm.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/utils/scripts/ocm/ocm.py b/utils/scripts/ocm/ocm.py index 4fc3951b3..56d1b6e1f 100644 --- a/utils/scripts/ocm/ocm.py +++ b/utils/scripts/ocm/ocm.py @@ -1239,10 +1239,10 @@ def update_ocm_policy(self): subparsers = parser.add_subparsers( title="Available sub commands", help="Available sub commands" ) - # Argument of update_ocm_channel + # Argument of update_ocm_policy update_ocm_policy = subparsers.add_parser( "update_ocm_policy", - help="Parser to get osd changes in json file", + help="Parser to update_ocm_channel", formatter_class=argparse.ArgumentDefaultsHelpFormatter, ) update_ocm_policy.add_argument( @@ -1267,7 +1267,7 @@ def update_ocm_policy(self): # Argument of update_ocm_channel update_ocm_channel = subparsers.add_parser( "update_ocm_channel", - help="Parser to get osd changes in json file", + help="Parser to update_ocm_channel", formatter_class=argparse.ArgumentDefaultsHelpFormatter, ) update_ocm_channel.add_argument( From 459495bc07d599be6907e4da66d44f9ed0a7ab2d Mon Sep 17 00:00:00 2001 From: mwaykole Date: Mon, 31 Oct 2022 14:45:54 +0530 Subject: [PATCH 06/11] Add_osd_upgrade_cmd in ocm.py Signed-off-by: mwaykole --- utils/scripts/ocm/ocm.py | 42 ++++++++++++++-------------------------- 1 file changed, 15 insertions(+), 27 deletions(-) diff --git a/utils/scripts/ocm/ocm.py b/utils/scripts/ocm/ocm.py index 56d1b6e1f..4819ef969 100644 --- a/utils/scripts/ocm/ocm.py +++ b/utils/scripts/ocm/ocm.py @@ -1168,51 +1168,43 @@ def compare_with_old_version_file(self): write_data_in_json(filename=self.osd_latest_version_data, data=old_data) log.info("File is updated to : {} ".format(old_data)) - def change_cluster_channel_group(self): """update the channel using ocm cmd""" cluster_id = self.get_osd_cluster_id() run_change_channel_cmd = ( "ocm patch /api/clusters_mgmt/v1/clusters/{}" - " --body {}".format(cluster_id, self.update_ocm_channel_json)) + " --body {}".format(cluster_id, self.update_ocm_channel_json) + ) log.info(run_change_channel_cmd) ret = execute_command(run_change_channel_cmd) if ret is None: log.info( - "Failed to update the channel to {}".format( - self.cluster_name)) + "Failed to update the channel to {}".format(self.cluster_name)) return ret - def update_ocm_policy(self): """update cluster policy to schedule for upgrade osd""" cluster_id = self.get_osd_cluster_id() - utc_time_cmd = ( - ''' oc debug node/"$(oc get nodes | awk 'FNR == 2 {print $1}')"\ - -- chroot /host date -d '+7 min' -u '+%Y-%m-%dT%H:%M:%SZ' ''') + utc_time_cmd = ''' oc debug node/"$(oc get nodes | awk 'FNR == 2 {print $1}')"\ + -- chroot /host date -d '+7 min' -u '+%Y-%m-%dT%H:%M:%SZ' ''' utc_time = execute_command(utc_time_cmd) data = read_data_from_json(self.update_policies_json) data["next_run"] = utc_time.replace("\n", "") if data["version"] == "latest": - get_latest_upgrade_version = ( - "ocm get cluster {} |" - " jq -r '.version.available_upgrades | values'".format( - cluster_id)) + get_latest_upgrade_version = "ocm get cluster {} | jq -r '.version.available_upgrades | values'".format( + cluster_id) latest_upgrade_version = execute_command( get_latest_upgrade_version) - log.info("Version Available to Upgrade are ...{}".format( - latest_upgrade_version)) - latest_upgrade_version = ( - ast.literal_eval(latest_upgrade_version)[-1]) - + log.info( + "Version Available to Upgrade are ...{}".format(latest_upgrade_version) + ) + latest_upgrade_version = ast.literal_eval(latest_upgrade_version)[-1] data["version"] = latest_upgrade_version - write_data_in_json(self.update_policies_json, data) - schedule_cluster_upgrade = ( - "ocm post /api/clusters_mgmt/v1/clusters/{}/upgrade_policies" - " --body {}".format(cluster_id, self.update_policies_json)) + schedule_cluster_upgrade = "ocm post /api/clusters_mgmt/v1/clusters/{}/upgrade_policies"\ + " --body {}".format(cluster_id, self.update_policies_json) ret = execute_command(schedule_cluster_upgrade) if ret is None: log.info("Failed to Update the Upgrade Policy") @@ -1260,9 +1252,7 @@ def update_ocm_policy(self): metavar="", default="qeaisrhods-xyz", ) - update_ocm_policy.set_defaults( - func=ocm_obj.update_ocm_policy - ) + update_ocm_policy.set_defaults(func=ocm_obj.update_ocm_policy) # Argument of update_ocm_channel update_ocm_channel = subparsers.add_parser( @@ -1285,9 +1275,7 @@ def update_ocm_policy(self): metavar="", default="qeaisrhods-xyz", ) - update_ocm_channel.set_defaults( - func=ocm_obj.change_cluster_channel_group - ) + update_ocm_channel.set_defaults(func=ocm_obj.change_cluster_channel_group) # Argument parsers for get ods_latest version get_latest_osd_candidate_json = subparsers.add_parser( From 3ea47f9b62f41cbf2b688a54e2b6009465a63f2b Mon Sep 17 00:00:00 2001 From: mwaykole Date: Mon, 31 Oct 2022 14:54:31 +0530 Subject: [PATCH 07/11] Add_ods_upgrade_cmd in ocm.py Signed-off-by: mwaykole --- utils/scripts/ocm/ocm.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/utils/scripts/ocm/ocm.py b/utils/scripts/ocm/ocm.py index 4819ef969..75df1a6d1 100644 --- a/utils/scripts/ocm/ocm.py +++ b/utils/scripts/ocm/ocm.py @@ -1178,15 +1178,14 @@ def change_cluster_channel_group(self): log.info(run_change_channel_cmd) ret = execute_command(run_change_channel_cmd) if ret is None: - log.info( - "Failed to update the channel to {}".format(self.cluster_name)) + log.info("Failed to update the channel to {}".format(self.cluster_name)) return ret def update_ocm_policy(self): """update cluster policy to schedule for upgrade osd""" cluster_id = self.get_osd_cluster_id() - utc_time_cmd = ''' oc debug node/"$(oc get nodes | awk 'FNR == 2 {print $1}')"\ - -- chroot /host date -d '+7 min' -u '+%Y-%m-%dT%H:%M:%SZ' ''' + utc_time_cmd = """ oc debug node/"$(oc get nodes | awk 'FNR == 2 {print $1}')"\ + -- chroot /host date -d '+7 min' -u '+%Y-%m-%dT%H:%M:%SZ' """ utc_time = execute_command(utc_time_cmd) data = read_data_from_json(self.update_policies_json) @@ -1195,16 +1194,17 @@ def update_ocm_policy(self): if data["version"] == "latest": get_latest_upgrade_version = "ocm get cluster {} | jq -r '.version.available_upgrades | values'".format( cluster_id) - latest_upgrade_version = execute_command( - get_latest_upgrade_version) + latest_upgrade_version = execute_command(get_latest_upgrade_version) log.info( "Version Available to Upgrade are ...{}".format(latest_upgrade_version) ) latest_upgrade_version = ast.literal_eval(latest_upgrade_version)[-1] data["version"] = latest_upgrade_version write_data_in_json(self.update_policies_json, data) - schedule_cluster_upgrade = "ocm post /api/clusters_mgmt/v1/clusters/{}/upgrade_policies"\ + schedule_cluster_upgrade = ( + "ocm post /api/clusters_mgmt/v1/clusters/{}/upgrade_policies"\ " --body {}".format(cluster_id, self.update_policies_json) + ) ret = execute_command(schedule_cluster_upgrade) if ret is None: log.info("Failed to Update the Upgrade Policy") From 76c1ebf3a29d8bef143cc4261cb5960f149b923c Mon Sep 17 00:00:00 2001 From: mwaykole Date: Mon, 31 Oct 2022 14:58:56 +0530 Subject: [PATCH 08/11] Add_ods_upgrade_cmd in ocm.py Signed-off-by: mwaykole --- utils/scripts/ocm/ocm.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/utils/scripts/ocm/ocm.py b/utils/scripts/ocm/ocm.py index 75df1a6d1..7de1e406b 100644 --- a/utils/scripts/ocm/ocm.py +++ b/utils/scripts/ocm/ocm.py @@ -1193,7 +1193,8 @@ def update_ocm_policy(self): if data["version"] == "latest": get_latest_upgrade_version = "ocm get cluster {} | jq -r '.version.available_upgrades | values'".format( - cluster_id) + cluster_id + ) latest_upgrade_version = execute_command(get_latest_upgrade_version) log.info( "Version Available to Upgrade are ...{}".format(latest_upgrade_version) From b75e4dc25931e951f7fa0f5c572a97992fa43f2d Mon Sep 17 00:00:00 2001 From: mwaykole Date: Mon, 31 Oct 2022 15:03:56 +0530 Subject: [PATCH 09/11] Add_ods_upgrade_cmd in ocm.py Signed-off-by: mwaykole --- utils/scripts/ocm/ocm.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/utils/scripts/ocm/ocm.py b/utils/scripts/ocm/ocm.py index 7de1e406b..1ae0c2eea 100644 --- a/utils/scripts/ocm/ocm.py +++ b/utils/scripts/ocm/ocm.py @@ -1198,7 +1198,7 @@ def update_ocm_policy(self): latest_upgrade_version = execute_command(get_latest_upgrade_version) log.info( "Version Available to Upgrade are ...{}".format(latest_upgrade_version) - ) + ) latest_upgrade_version = ast.literal_eval(latest_upgrade_version)[-1] data["version"] = latest_upgrade_version write_data_in_json(self.update_policies_json, data) From 865d2389feb1fb4384bebada0c84042871b3e05e Mon Sep 17 00:00:00 2001 From: mwaykole Date: Mon, 31 Oct 2022 15:14:44 +0530 Subject: [PATCH 10/11] Add_ods_upgrade_cmd in ocm.py Signed-off-by: mwaykole --- utils/scripts/ocm/ocm.py | 1 + 1 file changed, 1 insertion(+) diff --git a/utils/scripts/ocm/ocm.py b/utils/scripts/ocm/ocm.py index 1ae0c2eea..fa385f213 100644 --- a/utils/scripts/ocm/ocm.py +++ b/utils/scripts/ocm/ocm.py @@ -1202,6 +1202,7 @@ def update_ocm_policy(self): latest_upgrade_version = ast.literal_eval(latest_upgrade_version)[-1] data["version"] = latest_upgrade_version write_data_in_json(self.update_policies_json, data) + # fmt: off schedule_cluster_upgrade = ( "ocm post /api/clusters_mgmt/v1/clusters/{}/upgrade_policies"\ " --body {}".format(cluster_id, self.update_policies_json) From 1ad21c7936cbc7a52d7257d55b6aca73dec334ba Mon Sep 17 00:00:00 2001 From: mwaykole Date: Mon, 31 Oct 2022 15:35:28 +0530 Subject: [PATCH 11/11] Add_ods_upgrade_cmd in ocm.py Signed-off-by: mwaykole --- utils/scripts/ocm/ocm.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/utils/scripts/ocm/ocm.py b/utils/scripts/ocm/ocm.py index fa385f213..e670a20f7 100644 --- a/utils/scripts/ocm/ocm.py +++ b/utils/scripts/ocm/ocm.py @@ -1204,7 +1204,7 @@ def update_ocm_policy(self): write_data_in_json(self.update_policies_json, data) # fmt: off schedule_cluster_upgrade = ( - "ocm post /api/clusters_mgmt/v1/clusters/{}/upgrade_policies"\ + "ocm post /api/clusters_mgmt/v1/clusters/{}/upgrade_policies" " --body {}".format(cluster_id, self.update_policies_json) ) ret = execute_command(schedule_cluster_upgrade)