在Airflow DAG中使用BashOperator或SparkSubmitOperator来向Spark/Yarn发送Kill进程信号。示例代码如下：

使用BashOperator：

from airflow.operators.bash_operator import BashOperator

kill_spark_task = BashOperator(
    task_id='kill_spark_job',
    bash_command='yarn application -kill ',
    dag=dag
)

使用SparkSubmitOperator：

from airflow.contrib.operators.spark_submit_operator import SparkSubmitOperator

kill_spark_task = SparkSubmitOperator(
    task_id='kill_spark_job',
    application='',
    application_args=['--kill', ''],
    dag=dag
)

在以上示例代码中，是Spark应用程序的标识符，用于唯一标识正在运行的Spark作业。将其替换为您要杀死的Spark作业的ID即可。

此外，您还可以使用Spark REST API来向Spark/Yarn发送Kill进程信号。例如：

import requests

response = requests.post(
    'http:///v1/submissions/kill/',
    auth=('username', 'password')
)

其中，是Spark master的URL，是Spark应用程序的ID。在发送请求时，需要使用您的用户名和密码进行身份验证。