code: def __init__(self, path):
      self.path = path
  
file_path: airflow/tests/listeners/file_write_listener.py
imports: from __future__ import annotations
  import logging
  from airflow.cli.commands.task_command import TaskCommandMarker
  from airflow.listeners import hookimpl
label_desc: Use image node_id 1 to create a new FileWriteListener object  with example: obj = FileWriteListener(path)