code: def create_ensemble(workflow, model):
      serving_operators = (
          workflow.input_schema.column_names
          >> TransformWorkflow(workflow)
          >> PredictTensorflow(model)
      )
      ensemble = Ensemble(serving_operators, workflow.input_schema)
      return ensemble
  
file_path: Merlin/examples/sagemaker-tensorflow/train.py
imports: import argparse
  import json
  import logging
  import os
  import sys
  import tempfile
  import merlin.io
  import merlin.models.tf
  import nvtabular
  import tensorflow
  from merlin.schema.tags import Tags
  from merlin.systems.dag.ops.workflow import TransformWorkflow
  from merlin.systems.dag.ops.tensorflow import PredictTensorflow
  from merlin.systems.dag.ensemble import Ensemble
  import numpy
  from nvtabular.ops import *
label_desc: Use image node_id 3 for calling a global function with example usage: create_ensemble(workflow, model) and returns: ensemble