def METHOD_NAME():
    if len(sys.argv) < 7:
        print(
            "usage: ./write_parquet <ipc_socket> <path> <stream id> "
            "<storage_options> <write_options> <proc_num> <proc_index>"
        )
        sys.exit(1)
    ipc_socket = sys.argv[1]
    path = expand_full_path(sys.argv[2])
    stream_id = sys.argv[3]
    storage_options = json.loads(
        base64.b64decode(sys.argv[4].encode("utf-8")).decode("utf-8")
    )
    write_options = json.loads(
        base64.b64decode(sys.argv[5].encode("utf-8")).decode("utf-8")
    )
    if 'chunk_hook' in write_options:
        write_options['chunk_hook'] = cloudpickle.loads(
            base64.b64decode(write_options['chunk_hook'].encode('ascii'))
        )
    proc_num = int(sys.argv[6])
    proc_index = int(sys.argv[7])
    write_parquet(
        ipc_socket,
        path,
        stream_id,
        storage_options,
        write_options,
        proc_num,
        proc_index,
    )