class_docstr: Class to Create and Update FeatureProcessor Lineage Entities.
  
  Attributes:
      pipeline_name (str): Pipeline Name.
      pipeline_arn (str): The ARN of the Pipeline.
      pipeline (str): The details of the Pipeline.
      inputs (Sequence[Union[FeatureGroupDataSource, CSVDataSource, ParquetDataSource,
          BaseDataSource]]): The inputs to the Feature processor.
      output (str): The output Feature Group.
      transformation_code (TransformationCode): The Transformation Code for Feature Processor.
      sagemaker_session (Session): Session object which manages interactions
          with Amazon SageMaker APIs and any other AWS services needed. If not specified, the
          function creates one using the default AWS configuration chain.
class_docstr_tok: ["Class","to","Create","and","Update","FeatureProcessor","Lineage","Entities",".","Attributes",":","pipeline_name","(","str",")",":","Pipeline","Name",".","pipeline_arn","(","str",")",":","The","ARN","of","the","Pipeline",".","pipeline","(","str",")",":","The","details","of","the","Pipeline",".","inputs","(","Sequence","[","Union","[","FeatureGroupDataSource",",","CSVDataSource",",","ParquetDataSource",",","BaseDataSource","]","]",")",":","The","inputs","to","the","Feature","processor",".","output","(","str",")",":","The","output","Feature","Group",".","transformation_code","(","TransformationCode",")",":","The","Transformation","Code","for","Feature","Processor",".","sagemaker_session","(","Session",")",":","Session","object","which","manages","interactions","with","Amazon","SageMaker","APIs","and","any","other","AWS","services","needed",".","If","not","specified",",","the","function","creates","one","using","the","default","AWS","configuration","chain","."]
docstr: Create pipeline lineage resources.
code: def _create_new_pipeline_lineage(
      self,
      input_feature_group_contexts: List[FeatureGroupContexts],
      input_raw_data_artifacts: List[Artifact],
      output_feature_group_contexts: FeatureGroupContexts,
      transformation_code_artifact: Optional[Artifact],
  ) -> None:
      """Create pipeline lineage resources."""
  
      pipeline_context = (
          self._create_pipeline_lineage_for_new_pipeline()
      )
      pipeline_version_context = self._create_pipeline_version_lineage()
      self._add_associations_for_pipeline(
          # pylint: disable=no-member
          pipeline_context_arn=pipeline_context.context_arn,
          # pylint: disable=no-member
          pipeline_versions_context_arn=pipeline_version_context.context_arn,
          input_feature_group_contexts=input_feature_group_contexts,
          input_raw_data_artifacts=input_raw_data_artifacts,
          output_feature_group_contexts=output_feature_group_contexts,
          transformation_code_artifact=transformation_code_artifact,
      )
      LineageAssociationHandler.add_pipeline_and_pipeline_version_association(
          # pylint: disable=no-member
          pipeline_context_arn=pipeline_context.context_arn,
          # pylint: disable=no-member
          pipeline_version_context_arn=pipeline_version_context.context_arn,
          sagemaker_session=self.sagemaker_session,
      )
  
imports: from __future__ import absolute_import
  import logging
  from datetime import datetime
  from typing import Optional, Iterator, List, Dict, Set, Sequence, Union
  import attr
  from botocore.exceptions import ClientError
  from sagemaker.feature_store.feature_processor._event_bridge_rule_helper import EventBridgeRuleHelper
  from sagemaker.feature_store.feature_processor._event_bridge_scheduler_helper import EventBridgeSchedulerHelper
  from sagemaker.feature_store.feature_processor.lineage._lineage_association_handler import LineageAssociationHandler
  from sagemaker.feature_store.feature_processor.lineage._feature_group_lineage_entity_handler import FeatureGroupLineageEntityHandler
  from sagemaker.feature_store.feature_processor.lineage._feature_group_contexts import FeatureGroupContexts
  from sagemaker.feature_store.feature_processor.lineage._pipeline_lineage_entity_handler import PipelineLineageEntityHandler
  from sagemaker.feature_store.feature_processor.lineage._pipeline_schedule import PipelineSchedule
  from sagemaker.feature_store.feature_processor.lineage._pipeline_trigger import PipelineTrigger
  from sagemaker.feature_store.feature_processor.lineage._pipeline_version_lineage_entity_handler import PipelineVersionLineageEntityHandler
  from sagemaker.feature_store.feature_processor.lineage._s3_lineage_entity_handler import S3LineageEntityHandler
  from sagemaker.feature_store.feature_processor.lineage._transformation_code import TransformationCode
  from sagemaker.feature_store.feature_processor.lineage.constants import SAGEMAKER, LAST_UPDATE_TIME, PIPELINE_CONTEXT_NAME_KEY, PIPELINE_CONTEXT_VERSION_NAME_KEY, FEATURE_GROUP_PIPELINE_VERSION_CONTEXT_TYPE, DATA_SET, TRANSFORMATION_CODE, CREATION_TIME, RESOURCE_NOT_FOUND, ERROR, CODE, LAST_MODIFIED_TIME, TRANSFORMATION_CODE_STATUS_INACTIVE, TRANSFORMATION_CODE_STATUS_ACTIVE, CONTRIBUTED_TO
  from sagemaker.lineage.context import Context
  from sagemaker.lineage.artifact import Artifact
  from sagemaker.lineage.association import AssociationSummary
  from sagemaker import Session
  from sagemaker.feature_store.feature_processor._data_source import CSVDataSource, FeatureGroupDataSource, ParquetDataSource, BaseDataSource
label_desc: Use image node_id 6 for calling the FeatureProcessorLineageHandler obj's underlying member method code with example usage: obj._create_new_pipeline_lineage(input_feature_group_contexts, input_raw_data_artifacts, output_feature_group_contexts, transformation_code_artifact) without return types