DataPipelineNode

pydantic model openapi_client.models.data_pipeline_node.DataPipelineNode

Discriminated union of Glue and AI Flow node models. ModuleType selects the variant. Shared by POST /data-pipelines, PUT /data-pipelines/{id}, and GET /data-pipelines/{id} details. Not used for execution node payloads.

Fields:

• actual_instance (openapi_client.models.ai_flow_collector_node.AiFlowCollectorNode | openapi_client.models.ai_flow_condition_node.AiFlowConditionNode | openapi_client.models.ai_flow_input_node.AiFlowInputNode | openapi_client.models.ai_flow_iterator_node.AiFlowIteratorNode | openapi_client.models.ai_flow_knowledge_base_node.AiFlowKnowledgeBaseNode | openapi_client.models.ai_flow_lambda_function_node.AiFlowLambdaFunctionNode | openapi_client.models.ai_flow_output_node.AiFlowOutputNode | openapi_client.models.ai_flow_retrieval_node.AiFlowRetrievalNode | openapi_client.models.ai_flow_storage_node.AiFlowStorageNode | openapi_client.models.glue_agent_node.GlueAgentNode | openapi_client.models.glue_bda_node.GlueBdaNode | openapi_client.models.glue_child_pipeline_node.GlueChildPipelineNode | openapi_client.models.glue_comprehend_node.GlueComprehendNode | openapi_client.models.glue_datasource_node.GlueDatasourceNode | openapi_client.models.glue_email_node.GlueEmailNode | openapi_client.models.glue_end_node.GlueEndNode | openapi_client.models.glue_etl_job_node.GlueEtlJobNode | openapi_client.models.glue_file_load_validation_node.GlueFileLoadValidationNode | openapi_client.models.glue_llm_extraction_node.GlueLlmExtractionNode | openapi_client.models.glue_llm_node.GlueLlmNode | openapi_client.models.glue_medical_comprehend_node.GlueMedicalComprehendNode | openapi_client.models.glue_medical_transcribe_node.GlueMedicalTranscribeNode | openapi_client.models.glue_ml_model_inference_node.GlueMlModelInferenceNode | openapi_client.models.glue_rekognition_node.GlueRekognitionNode | openapi_client.models.glue_split_doc_node.GlueSplitDocNode | openapi_client.models.glue_start_node.GlueStartNode | openapi_client.models.glue_sync_to_s3_node.GlueSyncToS3Node | openapi_client.models.glue_textract_node.GlueTextractNode | openapi_client.models.glue_transcribe_node.GlueTranscribeNode | openapi_client.models.glue_translate_node.GlueTranslateNode | None)

• one_of_schemas (Set[str])

• oneof_schema_10_validator (openapi_client.models.glue_comprehend_node.GlueComprehendNode | None)

• oneof_schema_11_validator (openapi_client.models.glue_medical_comprehend_node.GlueMedicalComprehendNode | None)

• oneof_schema_12_validator (openapi_client.models.glue_transcribe_node.GlueTranscribeNode | None)

• oneof_schema_13_validator (openapi_client.models.glue_medical_transcribe_node.GlueMedicalTranscribeNode | None)

• oneof_schema_14_validator (openapi_client.models.glue_child_pipeline_node.GlueChildPipelineNode | None)

• oneof_schema_15_validator (openapi_client.models.glue_sync_to_s3_node.GlueSyncToS3Node | None)

• oneof_schema_16_validator (openapi_client.models.glue_file_load_validation_node.GlueFileLoadValidationNode | None)

• oneof_schema_17_validator (openapi_client.models.glue_agent_node.GlueAgentNode | None)

• oneof_schema_18_validator (openapi_client.models.glue_llm_node.GlueLlmNode | None)

• oneof_schema_19_validator (openapi_client.models.glue_llm_extraction_node.GlueLlmExtractionNode | None)

• oneof_schema_1_validator (openapi_client.models.glue_start_node.GlueStartNode | None)

• oneof_schema_20_validator (openapi_client.models.glue_bda_node.GlueBdaNode | None)

• oneof_schema_21_validator (openapi_client.models.glue_split_doc_node.GlueSplitDocNode | None)

• oneof_schema_22_validator (openapi_client.models.ai_flow_input_node.AiFlowInputNode | None)

• oneof_schema_23_validator (openapi_client.models.ai_flow_output_node.AiFlowOutputNode | None)

• oneof_schema_24_validator (openapi_client.models.ai_flow_knowledge_base_node.AiFlowKnowledgeBaseNode | None)

• oneof_schema_25_validator (openapi_client.models.ai_flow_lambda_function_node.AiFlowLambdaFunctionNode | None)

• oneof_schema_26_validator (openapi_client.models.ai_flow_condition_node.AiFlowConditionNode | None)

• oneof_schema_27_validator (openapi_client.models.ai_flow_iterator_node.AiFlowIteratorNode | None)

• oneof_schema_28_validator (openapi_client.models.ai_flow_collector_node.AiFlowCollectorNode | None)

• oneof_schema_29_validator (openapi_client.models.ai_flow_retrieval_node.AiFlowRetrievalNode | None)

• oneof_schema_2_validator (openapi_client.models.glue_end_node.GlueEndNode | None)

• oneof_schema_30_validator (openapi_client.models.ai_flow_storage_node.AiFlowStorageNode | None)

• oneof_schema_3_validator (openapi_client.models.glue_etl_job_node.GlueEtlJobNode | None)

• oneof_schema_4_validator (openapi_client.models.glue_datasource_node.GlueDatasourceNode | None)

• oneof_schema_5_validator (openapi_client.models.glue_ml_model_inference_node.GlueMlModelInferenceNode | None)

• oneof_schema_6_validator (openapi_client.models.glue_email_node.GlueEmailNode | None)

• oneof_schema_7_validator (openapi_client.models.glue_textract_node.GlueTextractNode | None)

• oneof_schema_8_validator (openapi_client.models.glue_rekognition_node.GlueRekognitionNode | None)

• oneof_schema_9_validator (openapi_client.models.glue_translate_node.GlueTranslateNode | None)

field oneof_schema_1_validator: Optional[GlueStartNode] = None

field oneof_schema_2_validator: Optional[GlueEndNode] = None

field oneof_schema_3_validator: Optional[GlueEtlJobNode] = None

field oneof_schema_4_validator: Optional[GlueDatasourceNode] = None

field oneof_schema_5_validator: Optional[GlueMlModelInferenceNode] = None

field oneof_schema_6_validator: Optional[GlueEmailNode] = None

field oneof_schema_7_validator: Optional[GlueTextractNode] = None

field oneof_schema_8_validator: Optional[GlueRekognitionNode] = None

field oneof_schema_9_validator: Optional[GlueTranslateNode] = None

field oneof_schema_10_validator: Optional[GlueComprehendNode] = None

field oneof_schema_11_validator: Optional[GlueMedicalComprehendNode] = None

field oneof_schema_12_validator: Optional[GlueTranscribeNode] = None

field oneof_schema_13_validator: Optional[GlueMedicalTranscribeNode] = None

field oneof_schema_14_validator: Optional[GlueChildPipelineNode] = None

field oneof_schema_15_validator: Optional[GlueSyncToS3Node] = None

field oneof_schema_16_validator: Optional[GlueFileLoadValidationNode] = None

field oneof_schema_17_validator: Optional[GlueAgentNode] = None

field oneof_schema_18_validator: Optional[GlueLlmNode] = None

field oneof_schema_19_validator: Optional[GlueLlmExtractionNode] = None

field oneof_schema_20_validator: Optional[GlueBdaNode] = None

field oneof_schema_21_validator: Optional[GlueSplitDocNode] = None

field oneof_schema_22_validator: Optional[AiFlowInputNode] = None

field oneof_schema_23_validator: Optional[AiFlowOutputNode] = None

field oneof_schema_24_validator: Optional[AiFlowKnowledgeBaseNode] = None

field oneof_schema_25_validator: Optional[AiFlowLambdaFunctionNode] = None

field oneof_schema_26_validator: Optional[AiFlowConditionNode] = None

field oneof_schema_27_validator: Optional[AiFlowIteratorNode] = None

field oneof_schema_28_validator: Optional[AiFlowCollectorNode] = None

field oneof_schema_29_validator: Optional[AiFlowRetrievalNode] = None

field oneof_schema_30_validator: Optional[AiFlowStorageNode] = None

field actual_instance: Optional[Union[AiFlowCollectorNode, AiFlowConditionNode, AiFlowInputNode, AiFlowIteratorNode, AiFlowKnowledgeBaseNode, AiFlowLambdaFunctionNode, AiFlowOutputNode, AiFlowRetrievalNode, AiFlowStorageNode, GlueAgentNode, GlueBdaNode, GlueChildPipelineNode, GlueComprehendNode, GlueDatasourceNode, GlueEmailNode, GlueEndNode, GlueEtlJobNode, GlueFileLoadValidationNode, GlueLlmExtractionNode, GlueLlmNode, GlueMedicalComprehendNode, GlueMedicalTranscribeNode, GlueMlModelInferenceNode, GlueRekognitionNode, GlueSplitDocNode, GlueStartNode, GlueSyncToS3Node, GlueTextractNode, GlueTranscribeNode, GlueTranslateNode]] = None

field one_of_schemas: Set[str] = {'AiFlowCollectorNode', 'AiFlowConditionNode', 'AiFlowInputNode', 'AiFlowIteratorNode', 'AiFlowKnowledgeBaseNode', 'AiFlowLambdaFunctionNode', 'AiFlowOutputNode', 'AiFlowRetrievalNode', 'AiFlowStorageNode', 'GlueAgentNode', 'GlueBdaNode', 'GlueChildPipelineNode', 'GlueComprehendNode', 'GlueDatasourceNode', 'GlueEmailNode', 'GlueEndNode', 'GlueEtlJobNode', 'GlueFileLoadValidationNode', 'GlueLlmExtractionNode', 'GlueLlmNode', 'GlueMedicalComprehendNode', 'GlueMedicalTranscribeNode', 'GlueMlModelInferenceNode', 'GlueRekognitionNode', 'GlueSplitDocNode', 'GlueStartNode', 'GlueSyncToS3Node', 'GlueTextractNode', 'GlueTranscribeNode', 'GlueTranslateNode'}

__init__(*args, **kwargs)

Create a new model by parsing and validating input data from keyword arguments.

Raises [ValidationError][pydantic_core.ValidationError] if the input data cannot be validated to form a valid model.

self is explicitly positional-only to allow self as a field name.

classmethod from_dict(obj)

Return type:

Self

classmethod from_json(json_str)

Returns the object represented by the json string

Return type:

Self

to_json()

Returns the JSON representation of the actual instance

Return type:

str

to_dict()

Returns the dict representation of the actual instance

Return type:

Union[Dict[str, Any], AiFlowCollectorNode, AiFlowConditionNode, AiFlowInputNode, AiFlowIteratorNode, AiFlowKnowledgeBaseNode, AiFlowLambdaFunctionNode, AiFlowOutputNode, AiFlowRetrievalNode, AiFlowStorageNode, GlueAgentNode, GlueBdaNode, GlueChildPipelineNode, GlueComprehendNode, GlueDatasourceNode, GlueEmailNode, GlueEndNode, GlueEtlJobNode, GlueFileLoadValidationNode, GlueLlmExtractionNode, GlueLlmNode, GlueMedicalComprehendNode, GlueMedicalTranscribeNode, GlueMlModelInferenceNode, GlueRekognitionNode, GlueSplitDocNode, GlueStartNode, GlueSyncToS3Node, GlueTextractNode, GlueTranscribeNode, GlueTranslateNode, None]

to_str()

Returns the string representation of the actual instance

Return type:

str