Escribir en un archivo en disco usando Airflow no está funcionando.

Estoy usando una máquina Windows y he creado un contenedor para Airflow. Puedo leer datos en el sistema de archivos local a través del DAG, pero no puedo escribir datos en un archivo. También he intentado proporcionar una ruta completa e intentado con diferentes operadores: Python y Bash, pero aún no funciona. El DAG tiene éxito, no hay fallos que mostrar.
Nota: /opt/airflow es la ruta $AIRFLOW_HOME.
¿Cuál podría ser la razón?

Un fragmento de código:

from airflow import DAG
from datetime import datetime
from airflow.operators.python import PythonOperator
from airflow.operators.bash import BashOperator

def pre_process():
    f = open("/opt/airflow/write.txt", "w")
    f.write("world")
    f.close()

with DAG(dag_id="testdata", start_date=datetime(2021, 11, 24), schedule_interval='@daily') as dag:
    check_file = BashOperator(
        task_id="check_file",
        bash_command="echo Hi > /opt/airflow/hi.txt "
    )
    pre_processing = PythonOperator(
        task_id="pre_process",
        python_callable=pre_process
    )
    check_file >> pre_processing