code: def create(
      obj,
      file,
      authorize=None,
      generate_new_token=False,
      given_token=None,
      tags=None,
      is_paused_upon_creation=False,
      user_namespace=None,
      max_workers=None,
      workflow_timeout=None,
      worker_pool=None,
  ):
      if os.path.abspath(sys.argv[0]) == os.path.abspath(file):
          raise MetaflowException(
              "Airflow DAG file name cannot be the same as flow file name"
          )
  
      # Validate if the workflow is correctly parsed.
      _validate_workflow(
          obj.flow,
          obj.graph,
          obj.flow_datastore,
          obj.metadata,
          workflow_timeout,
      )
  
      obj.echo(
          "Compiling *%s* to Airflow DAG..." % obj.dag_name, bold=True
      )
      token = resolve_token(
          obj.dag_name,
          obj.token_prefix,
          obj,
          authorize,
          given_token,
          generate_new_token,
          obj.is_project,
      )
  
      flow = make_flow(
          obj,
          obj.dag_name,
          token,
          tags,
          is_paused_upon_creation,
          user_namespace,
          max_workers,
          workflow_timeout,
          worker_pool,
          file,
      )
      with open(file, "w") as f:
          f.write(flow.compile())
  
      obj.echo(
          "DAG *{dag_name}* "
          "for flow *{name}* compiled to "
          "Airflow successfully.\n".format(
              dag_name=obj.dag_name, name=current.flow_name
          ),
          bold=True,
      )
  
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 4 for calling a global function with example usage: create(obj, file, authorize, generate_new_token, given_token, tags, is_paused_upon_creation, user_namespace, max_workers, workflow_timeout, worker_pool) without return types