diff --git a/src/caret_analyze/infra/lttng/event_counter.py b/src/caret_analyze/infra/lttng/event_counter.py index 400895197..327877389 100644 --- a/src/caret_analyze/infra/lttng/event_counter.py +++ b/src/caret_analyze/infra/lttng/event_counter.py @@ -260,7 +260,8 @@ def ns_and_node_name(ns: str, name: str) -> str: timer_handle_to_node_name.get(handler, '-') for handler, row in data.subscriptions.df.iterrows(): - rmw_handle_to_node_name[row['rmw_handle']] = node_handle_to_node_name[row['node_handle']] + rmw_handle_to_node_name[row['rmw_handle']] = \ + node_handle_to_node_name[row['node_handle']] rmw_handle_to_topic_name[row['rmw_handle']] = row['topic_name'] tilde_pub_to_topic_name: dict[int, str] = {} diff --git a/src/caret_analyze/infra/lttng/ros2_tracing/data_model_service.py b/src/caret_analyze/infra/lttng/ros2_tracing/data_model_service.py index e238a8f22..9face0af2 100644 --- a/src/caret_analyze/infra/lttng/ros2_tracing/data_model_service.py +++ b/src/caret_analyze/infra/lttng/ros2_tracing/data_model_service.py @@ -194,7 +194,6 @@ def _get_rmw_handle_from_callback_object( except KeyError: return [None] - @staticmethod def _ensure_dataframe( dataframe_or_series: pd.DataFrame | pd.Series diff --git a/src/caret_analyze/runtime/path.py b/src/caret_analyze/runtime/path.py index 02128f7d8..745f15281 100644 --- a/src/caret_analyze/runtime/path.py +++ b/src/caret_analyze/runtime/path.py @@ -231,7 +231,8 @@ def _merge_records( left_records.sort(first_column) # search drop columns, which contain 'source_timestamp' - source_columns = [column for column in left_records.columns if 'source_timestamp' in column] + source_columns = \ + [column for column in left_records.columns if 'source_timestamp' in column] left_records.drop_columns(source_columns) return left_records