code: def __init__(self, fn, task_id, reply_queue, isolated_connection):
      self.fn = fn
      self.task_id = task_id
      self.reply_queue = reply_queue
      self.isolated_connection = isolated_connection
  
imports: import asyncio
  from collections import namedtuple
  from pathlib import Path
  import hashlib
  import janus
  import queue
  import sys
  import threading
  import uuid
  from .tracer import trace
  from .utils import detect_fts, detect_primary_keys, detect_spatialite, get_all_foreign_keys, get_outbound_foreign_keys, sqlite_timelimit, sqlite3, table_columns, table_column_details
  from .inspect import inspect_hash
label_desc: Use image node_id 1 to create a new WriteTask object  with example: obj = WriteTask(fn, task_id, reply_queue, isolated_connection)