code: def make_flow(
      obj,
      dag_name,
      production_token,
      tags,
      is_paused_upon_creation,
      namespace,
      max_workers,
      workflow_timeout,
      worker_pool,
      file,
  ):
      # Attach @kubernetes.
      decorators._attach_decorators(
          obj.flow, [KubernetesDecorator.name]
      )
  
      decorators._init_step_decorators(
          obj.flow,
          obj.graph,
          obj.environment,
          obj.flow_datastore,
          obj.logger,
      )
  
      # Save the code package in the flow datastore so that both user code and
      # metaflow package can be retrieved during workflow execution.
      obj.package = MetaflowPackage(
          obj.flow, obj.environment, obj.echo, obj.package_suffixes
      )
      package_url, package_sha = obj.flow_datastore.save_data(
          [obj.package.blob], len_hint=1
      )[0]
  
      return Airflow(
          dag_name,
          obj.graph,
          obj.flow,
          package_sha,
          package_url,
          obj.metadata,
          obj.flow_datastore,
          obj.environment,
          obj.event_logger,
          obj.monitor,
          production_token,
          tags=tags,
          namespace=namespace,
          username=get_username(),
          max_workers=max_workers,
          worker_pool=worker_pool,
          workflow_timeout=workflow_timeout,
          description=obj.flow.__doc__,
          file_path=file,
          is_paused_upon_creation=is_paused_upon_creation,
      )
  
imports: import base64
  import os
  import re
  import sys
  from hashlib import sha1
  from metaflow import current, decorators
  from metaflow._vendor import click
  from metaflow.exception import MetaflowException, MetaflowInternalError
  from metaflow.package import MetaflowPackage
  from metaflow.plugins.aws.step_functions.production_token import load_token, new_token, store_token
  from metaflow.plugins.kubernetes.kubernetes_decorator import KubernetesDecorator
  from metaflow.util import get_username, to_bytes, to_unicode
  from .airflow import Airflow
  from .exception import AirflowException, NotSupportedException
label_desc: Use image node_id 5 for calling a global function with example usage: make_flow(obj, dag_name, production_token, tags, is_paused_upon_creation, namespace, max_workers, workflow_timeout, worker_pool, file) and returns: Airflow