code: def ts_pipeline_with_incorrect_data_flow():
      """
      Connection lagged -> lagged is incorrect
      Connection ridge -> ar is incorrect also
         lagged - lagged - ridge \
                                  ar -> final forecast
                  lagged - ridge /
      """
  
      # First level
      node_lagged = PipelineNode("lagged")
  
      # Second level
      node_lagged_1 = PipelineNode("lagged", nodes_from=[node_lagged])
      node_lagged_2 = PipelineNode("lagged")
  
      # Third level
      node_ridge_1 = PipelineNode("ridge", nodes_from=[node_lagged_1])
      node_ridge_2 = PipelineNode("ridge", nodes_from=[node_lagged_2])
  
      # Fourth level - root node
      node_final = PipelineNode(
          "ar", nodes_from=[node_ridge_1, node_ridge_2]
      )
      pipeline = Pipeline(node_final)
  
      return pipeline
  
imports: import pytest
  from fedot.core.pipelines.node import PipelineNode
  from fedot.core.pipelines.pipeline import Pipeline
  from fedot.core.pipelines.verification import verify_pipeline
  from fedot.core.pipelines.verification_rules import has_correct_operations_for_task, has_final_operation_as_model, has_no_conflicts_in_decompose, has_no_conflicts_with_data_flow, has_no_data_flow_conflicts_in_ts_pipeline, has_primary_nodes, only_non_lagged_operations_are_primary, has_correct_data_sources, has_parent_contain_single_resample, has_no_conflicts_during_multitask, has_no_conflicts_after_class_decompose
  from fedot.core.repository.tasks import Task, TaskTypesEnum
  from golem.core.dag.verification_rules import has_no_cycle
label_desc: Use image node_id 7 for calling a global function with example usage: ts_pipeline_with_incorrect_data_flow() and returns: pipeline