气流 + 哨兵 - 没有来自匕首/任务的信息

Question

我正在尝试开始使用哨兵从气流中获取信息。我正在使用最新版本的气流(从 v1.10.6 开始，哨兵与气流集成(。但是，我无法获得有关dag或任务状态的任何信息。

我准备了一些简单的达匕，应该会失败，但在哨兵上我什么也没收到。当我犯一些错别字时，例如在导入中，就会建立连接，错误信息会在哨兵处捕获。对于此示例，我使用了SequentialExecutor

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from airflow.utils.trigger_rule import TriggerRule

from airflow.utils.dates import days_ago
from airflow import AirflowException

################################################################################
# dag
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': days_ago(2),
'email': ['[e-mail]'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 0,
'retry_delay': timedelta(seconds=3),
}
dag = DAG(
'debug_sentry',
default_args=default_args,
schedule_interval=None,
)

################################################################################
# first_task
def _first_task_callable(*args, **kwargs):
pass

first_task = PythonOperator(
task_id='first_task',
python_callable=_first_task_callable,
provide_context=True,
trigger_rule=TriggerRule.ONE_SUCCESS,
dag=dag
)

################################################################################
# second_task_which_fails
def _second_task_which_fails_callable(*args, **kwargs):
a = 1
b = 0
c = a / b
return c
second_task_which_fails = PythonOperator(
task_id='second_task_which_fails',
python_callable=_second_task_which_fails_callable,
provide_context=True,
trigger_rule=TriggerRule.ONE_SUCCESS,
dag=dag
)
################################################################################
# third_task
def _third_task_callable(*args, **kwargs):
pass
third_task = PythonOperator(
task_id='third_task',
python_callable=_third_task_callable,
provide_context=True,
trigger_rule=TriggerRule.ONE_SUCCESS,
dag=dag
)

################################################################################
first_task >> second_task_which_fails >> third_task

我做错了什么或错过了airflow.cfg配置中的某些内容？

[sentry]
sentry_dsn = https://<my_dsn>

Answer 1

最近对Airflow 中的哨兵集成进行了修复，如下所示：https://github.com/apache/airflow/pull/7232。尝试将气流更新到此提交？