code: def make_dataflow_plan(node: BaseOutput) -> DataflowPlan:  # noqa: D
      return DataflowPlan(
          plan_id=IdGeneratorRegistry.for_class(
              ComputeMetricsBranchCombiner
          ).create_id(OPTIMIZED_DATAFLOW_PLAN_PREFIX),
          sink_output_nodes=[WriteToResultDataframeNode(node)],
      )
  
file_path: metricflow/metricflow/test/dataflow/optimizer/source_scan/test_cm_branch_combiner.py
imports: from __future__ import annotations
  import pytest
  from _pytest.fixtures import FixtureRequest
  from metricflow.dag.id_generation import OPTIMIZED_DATAFLOW_PLAN_PREFIX, IdGeneratorRegistry
  from metricflow.dataflow.dataflow_plan import BaseOutput, DataflowPlan, FilterElementsNode, WriteToResultDataframeNode
  from metricflow.dataflow.dataflow_plan_to_text import dataflow_plan_as_text
  from metricflow.dataflow.optimizer.source_scan.cm_branch_combiner import ComputeMetricsBranchCombiner, ComputeMetricsBranchCombinerResult
  from metricflow.specs.specs import InstanceSpecSet, MeasureSpec
  from metricflow.test.dataflow_plan_to_svg import display_graph_if_requested
  from metricflow.test.fixtures.model_fixtures import ConsistentIdObjectRepository
  from metricflow.test.fixtures.setup_fixtures import MetricFlowTestSessionState
  from metricflow.test.snapshot_utils import assert_plan_snapshot_text_equal
label_desc: Use image node_id 1 for calling a global function with example usage: make_dataflow_plan(node) and returns: DataflowPlan