Use SSHOperator to run an rm command if your server supports SSH: delete_task = SSHOperator( task_id='delete_file', ssh_conn_id='nseix', command='rm /remote/path/{{ ti.xcom_pull(key="del_td") }}.i01_1.spn', dag=dag )