code: def test_aggregate_pipeline_events_with_same_desired_status(
      event_bridge_rule_helper,
  ):
      events = [
          FeatureProcessorPipelineEvents(
              pipeline_name="test_pipeline_1",
              pipeline_execution_status=[
                  FeatureProcessorPipelineExecutionStatus.FAILED
              ],
          ),
          FeatureProcessorPipelineEvents(
              pipeline_name="test_pipeline_2",
              pipeline_execution_status=[
                  FeatureProcessorPipelineExecutionStatus.FAILED
              ],
          ),
      ]
  
      assert event_bridge_rule_helper._aggregate_pipeline_events_with_same_desired_status(
          events
      ) == {
          (FeatureProcessorPipelineExecutionStatus.FAILED,): [
              "test_pipeline_1",
              "test_pipeline_2",
          ]
      }
  
imports: from __future__ import absolute_import
  from mock import Mock
  from sagemaker.session import Session
  from sagemaker.feature_store.feature_processor._event_bridge_rule_helper import EventBridgeRuleHelper
  from botocore.exceptions import ClientError
  from sagemaker.feature_store.feature_processor._feature_processor_pipeline_events import FeatureProcessorPipelineEvents, FeatureProcessorPipelineExecutionStatus
  import pytest
label_desc: Use image node_id 16 for calling a global function with example usage: test_aggregate_pipeline_events_with_same_desired_status(event_bridge_rule_helper) without return types