diff --git a/msmonitor/plugin/ipc_monitor/InputParser.cpp b/msmonitor/plugin/ipc_monitor/InputParser.cpp index c18ffa72e5d69016d8d182d02dc6351c3c55f79a..7d43eb976a16c63c1868443e18305850f19ff394 100644 --- a/msmonitor/plugin/ipc_monitor/InputParser.cpp +++ b/msmonitor/plugin/ipc_monitor/InputParser.cpp @@ -61,7 +61,7 @@ std::set str2Kinds(const std::string& kindStrs) MsptiMonitorCfg InputParser::DynoLogGetOpts(std::unordered_map& cmd) { - if (cmd.count("NPU_MONITOR_SRART")) { + if (!cmd.count(NPU_MONITOR_START_KEY)) { return {{MSPTI_ACTIVITY_KIND_INVALID}, 0, false, false, false}; } auto activityKinds = str2Kinds(cmd[MSPTI_ACTIVITY_KIND_KEY]); diff --git a/profiler/affinity_cpu_bind/bind_core.py b/profiler/affinity_cpu_bind/bind_core.py index aeb0647d7dc9817e36b959d3e74e0ead0d3a02e4..344e997673b6ea948ef559de02bf4ea834861873 100644 --- a/profiler/affinity_cpu_bind/bind_core.py +++ b/profiler/affinity_cpu_bind/bind_core.py @@ -151,7 +151,7 @@ class BindCoreManager(): logging.info('Succeed to bind process %s on NPU %d with cpu cores list %s', pid, npu, affinity_cpu) def args_parse(self): - parser = argparse.ArgumentParser(description='This is a affinity cpu core bind script.') + parser = argparse.ArgumentParser(description='This is an affinity cpu core bind script.') parser.add_argument('-t', '--time', type=int, metavar='', help='Wait time before bind cores that you want to set. The unit is \'s\'.') parser.add_argument('-app', '--application', metavar='', nargs='+', diff --git a/profiler/msprof_analyze/cluster_analyse/analysis/msprof_step_trace_time_adapter.py b/profiler/msprof_analyze/cluster_analyse/analysis/msprof_step_trace_time_adapter.py index c71ea856175e1a88eefa3510dd0238a6fb39deec..aa4bacca3bd95e8406f8623ccd894357a6e52d1b 100644 --- a/profiler/msprof_analyze/cluster_analyse/analysis/msprof_step_trace_time_adapter.py +++ b/profiler/msprof_analyze/cluster_analyse/analysis/msprof_step_trace_time_adapter.py @@ -121,7 +121,7 @@ class MsprofStepTraceTimeDBAdapter(MsprofStepTraceTimeAdapter): self.string_id_map = {data[0]: data[1] for data in string_id_data} if DBManager.judge_table_exists(curs, TableConstant.TABLE_COMPUTE_TASK_INFO): sql = f"select TASK.startNs, TASK.endNs from {TableConstant.TABLE_COMPUTE_TASK_INFO} JOIN " \ - f"{TableConstant.TABLE_TASK} on {TableConstant.TABLE_TASK}.globalTaskId == " \ + f"{TableConstant.TABLE_TASK} on {TableConstant.TABLE_TASK}.globalTaskId = " \ f"{TableConstant.TABLE_COMPUTE_TASK_INFO}.globalTaskId" self.compute_task_info = DBManager.fetch_all_data(curs, sql, is_dict=False) if DBManager.judge_table_exists(curs, TableConstant.TABLE_COMMUNICATION_OP): diff --git a/profiler/msprof_analyze/prof_exports/cann_api_sum_export.py b/profiler/msprof_analyze/prof_exports/cann_api_sum_export.py index 456aac95f07fec30f9f87a7e401d14a7edc4ea05..d46f2fbeb9f6d87db673e4c4b41846c1d4e7f445 100644 --- a/profiler/msprof_analyze/prof_exports/cann_api_sum_export.py +++ b/profiler/msprof_analyze/prof_exports/cann_api_sum_export.py @@ -55,7 +55,7 @@ FROM summary LEFT JOIN STRING_IDS AS ids - ON ids.id == summary.name + ON ids.id = summary.name ORDER BY 2 DESC; """ diff --git a/profiler/msprof_analyze/prof_exports/compute_op_sum_export.py b/profiler/msprof_analyze/prof_exports/compute_op_sum_export.py index 24a2cc2d990976b5fa6e4c26a8b4dd745a88a767..fa2e0ffa23feb608c1604b92632d082a0a0fe870 100644 --- a/profiler/msprof_analyze/prof_exports/compute_op_sum_export.py +++ b/profiler/msprof_analyze/prof_exports/compute_op_sum_export.py @@ -26,19 +26,19 @@ SELECT FROM COMPUTE_TASK_INFO LEFT JOIN TASK - ON TASK.globalTaskId == COMPUTE_TASK_INFO.globalTaskId + ON TASK.globalTaskId = COMPUTE_TASK_INFO.globalTaskId LEFT JOIN STRING_IDS AS NAME_IDS - ON NAME_IDS.id == COMPUTE_TASK_INFO.name + ON NAME_IDS.id = COMPUTE_TASK_INFO.name LEFT JOIN STRING_IDS AS OPTYPE_IDS - ON OPTYPE_IDS.id == COMPUTE_TASK_INFO.opType + ON OPTYPE_IDS.id = COMPUTE_TASK_INFO.opType LEFT JOIN STRING_IDS AS TASKTYPE_IDS - ON TASKTYPE_IDS.id == COMPUTE_TASK_INFO.taskType + ON TASKTYPE_IDS.id = COMPUTE_TASK_INFO.taskType LEFT JOIN STRING_IDS AS INPUTSHAPES_IDS - ON INPUTSHAPES_IDS.id == COMPUTE_TASK_INFO.inputShapes + ON INPUTSHAPES_IDS.id = COMPUTE_TASK_INFO.inputShapes {} """ @@ -51,16 +51,16 @@ SELECT FROM COMPUTE_TASK_INFO LEFT JOIN TASK - ON TASK.globalTaskId == COMPUTE_TASK_INFO.globalTaskId + ON TASK.globalTaskId = COMPUTE_TASK_INFO.globalTaskId LEFT JOIN STRING_IDS AS OPTYPE_IDS - ON OPTYPE_IDS.id == COMPUTE_TASK_INFO.opType + ON OPTYPE_IDS.id = COMPUTE_TASK_INFO.opType LEFT JOIN STRING_IDS AS TASKTYPE_IDS - ON TASKTYPE_IDS.id == COMPUTE_TASK_INFO.taskType + ON TASKTYPE_IDS.id = COMPUTE_TASK_INFO.taskType LEFT JOIN STRING_IDS AS INPUTSHAPES_IDS - ON INPUTSHAPES_IDS.id == COMPUTE_TASK_INFO.inputShapes + ON INPUTSHAPES_IDS.id = COMPUTE_TASK_INFO.inputShapes {} """ diff --git a/profiler/msprof_analyze/prof_exports/hccl_sum_export.py b/profiler/msprof_analyze/prof_exports/hccl_sum_export.py index 80750ef88ddfeceb54b35f3083ce6f6a0ae318eb..13919e595cd5b9b690e670345da548e24dad4fe9 100644 --- a/profiler/msprof_analyze/prof_exports/hccl_sum_export.py +++ b/profiler/msprof_analyze/prof_exports/hccl_sum_export.py @@ -26,13 +26,13 @@ FROM COMMUNICATION_OP LEFT JOIN STRING_IDS AS TYPE_IDS - ON TYPE_IDS.id == COMMUNICATION_OP.opType + ON TYPE_IDS.id = COMMUNICATION_OP.opType LEFT JOIN STRING_IDS AS NAME_IDS - ON NAME_IDS.id == COMMUNICATION_OP.opName + ON NAME_IDS.id = COMMUNICATION_OP.opName LEFT JOIN STRING_IDS AS GROUP_NAME_IDS - ON GROUP_NAME_IDS.id == COMMUNICATION_OP.groupName + ON GROUP_NAME_IDS.id = COMMUNICATION_OP.groupName {} """ diff --git a/profiler/msprof_analyze/prof_exports/mstx2commop_export.py b/profiler/msprof_analyze/prof_exports/mstx2commop_export.py index f84b5e71407dfd1f5acb8594963177ebd863387e..b8a0b587dd0f2d10ab9be8e8e1a1249b3224b85f 100644 --- a/profiler/msprof_analyze/prof_exports/mstx2commop_export.py +++ b/profiler/msprof_analyze/prof_exports/mstx2commop_export.py @@ -25,10 +25,10 @@ FROM MSTX_EVENTS ms JOIN TASK ta - ON ms.connectionId == ta.connectionId + ON ms.connectionId = ta.connectionId JOIN STRING_IDS si - ON ms.message == si.id + ON ms.message = si.id WHERE si.value LIKE '%"streamId":%' AND si.value LIKE '%"count":%' diff --git a/profiler/msprof_analyze/prof_exports/mstx_event_export.py b/profiler/msprof_analyze/prof_exports/mstx_event_export.py index 76bf4672b616b94d639f75c89782b07f3a175dcc..3acbde5ea0fb733151ed36627fce817b14d988f3 100644 --- a/profiler/msprof_analyze/prof_exports/mstx_event_export.py +++ b/profiler/msprof_analyze/prof_exports/mstx_event_export.py @@ -26,7 +26,7 @@ WITH PYTORCH_API LEFT JOIN CONNECTION_IDS - ON PYTORCH_API.connectionId == CONNECTION_IDS.id + ON PYTORCH_API.connectionId = CONNECTION_IDS.id {} ) SELECT @@ -39,15 +39,15 @@ FROM MSTX_EVENTS LEFT JOIN TASK - ON MSTX_EVENTS.connectionId == TASK.connectionId + ON MSTX_EVENTS.connectionId = TASK.connectionId LEFT JOIN FRAMEWORK_API - ON MSTX_EVENTS.connectionId == FRAMEWORK_API.connectionId + ON MSTX_EVENTS.connectionId = FRAMEWORK_API.connectionId LEFT JOIN STRING_IDS AS MSG_IDS - ON MSTX_EVENTS.message == MSG_IDS.id + ON MSTX_EVENTS.message = MSG_IDS.id WHERE - MSTX_EVENTS.eventType == 3 {} + MSTX_EVENTS.eventType = 3 {} ORDER BY MSTX_EVENTS.startNs """ @@ -83,12 +83,12 @@ FROM MSTX_EVENTS LEFT JOIN TASK - ON MSTX_EVENTS.connectionId == TASK.connectionId + ON MSTX_EVENTS.connectionId = TASK.connectionId LEFT JOIN STRING_IDS AS MSG_IDS - ON MSTX_EVENTS.message == MSG_IDS.id + ON MSTX_EVENTS.message = MSG_IDS.id WHERE - MSTX_EVENTS.eventType == 2 {} + MSTX_EVENTS.eventType = 2 {} AND MSTX_EVENTS.connectionId != 4294967295 ORDER BY