code: def serialize_table(tbl):
      sink = pyarrow.BufferOutputStream()
      writer = pyarrow.RecordBatchStreamWriter(sink, tbl.schema)
      writer.write_table(tbl)
      writer.close()
      buf = sink.getvalue()
      header = {}
      frames = [buf]
      return header, frames
  
imports: from __future__ import annotations
  import pyarrow
  from distributed.protocol.serialize import dask_deserialize, dask_serialize
label_desc: Use image node_id 3 for calling a global function with example usage: serialize_table(tbl) and returns: header,  frames