code: def has_no_conflicts_with_data_flow(pipeline: Pipeline):
      """Check if the pipeline contains incorrect connections between nodes"""
      operation_repo = OperationTypesRepository(
          operation_type="data_operation"
      )
      forbidden_parents_combination = (
          operation_repo.suitable_operation()
      )
      forbidden_parents_combination = set(forbidden_parents_combination)
  
      for node in pipeline.nodes:
          parent_nodes = node.nodes_from
  
          if parent_nodes is not None and len(parent_nodes) > 1:
              # There are several parents
              operation_names = []
              for parent in parent_nodes:
                  operation_names.append(
                      parent.operation.operation_type
                  )
  
              # If operations are identical
              if len(set(operation_names)) == 1:
                  # And if it is forbidden to combine them
                  if (
                      operation_names[0]
                      in forbidden_parents_combination
                  ):
                      raise ValueError(
                          f"{ERROR_PREFIX} Pipeline has incorrect subgraph with identical data operations"
                      )
      return True
  
imports: from typing import Optional
  from fedot.core.operations.atomized_model import AtomizedModel
  from fedot.core.operations.model import Model
  from fedot.core.pipelines.node import PipelineNode
  from fedot.core.pipelines.pipeline import Pipeline
  from fedot.core.repository.dataset_types import DataTypesEnum
  from fedot.core.repository.operation_types_repository import OperationTypesRepository, get_operations_for_task, atomized_model_type
  from fedot.core.repository.tasks import Task, TaskTypesEnum
label_desc: Use image node_id 4 for calling a global function with example usage: has_no_conflicts_with_data_flow(pipeline) and returns: True