code: def _import_data(
      task: ImportTask, storage, load_host, resolve, name, version
  ):
      """Function to run import task.
  
      Set stream handler, launch load_database and set task status.
      """
      try:
          print("Import starting.", task.task_id)
          task.listen_logging()
          load_database(
              storage,
              load_host,
              resolve,
              name,
              version,
              progress_callback=task.set_progress,
          )
          task.set_completed(success=True)
      except Exception as exc:
          traceback.print_tb(exc.__traceback__)
          print("Import error.", exc)
          # Add error message to shared messages
          task.set_completed(
              success=False, notification=f"Error: {exc}"
          )
      finally:
          # Remove imported files
          os.unlink(load_host)
          lock_file = f"{load_host}.lock"
          if os.path.exists(lock_file):
              os.unlink(lock_file)
          print("Import terminated.")
  
imports: import json
  import logging
  import multiprocessing
  import os
  import traceback
  import uuid
  from datetime import datetime
  from queue import Empty
  import falcon
  from falcon import Request, Response
  from orion.core.io.database import DatabaseError
  from orion.core.utils import generate_temporary_file
  from orion.storage.backup import dump_database, load_database
label_desc: Use image node_id 1 for calling a global function with example usage: _import_data(task, storage, load_host, resolve, name, version) without return types