This is an automated email from the ASF dual-hosted git repository.
uranusjr pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 1e2e9e9a87b Fix duplicate mention of 'Dags' and 'tasks' in
overview.rst (#57524)
add 101f1accecc Reimplement Sentry integration in Task SDK (#57032)
No new revisions were added by this update.
Summary of changes:
airflow-core/docs/extra-packages-ref.rst | 16 +-
airflow-core/pyproject.toml | 7 +-
.../execution_api/datamodels/taskinstance.py | 7 +
.../execution_api/routes/task_instances.py | 18 +-
airflow-core/src/airflow/sentry.py | 196 -----------------
.../versions/head/test_task_instances.py | 69 ++++++
airflow-core/tests/unit/core/test_sentry.py | 197 -----------------
.../tests/unit/dag_processing/test_processor.py | 2 +
airflow-core/tests/unit/jobs/test_triggerer_job.py | 2 +
airflow-core/tests/unit/plugins/test_plugin.py | 24 +-
pyproject.toml | 11 +-
scripts/ci/prek/update_airflow_pyproject_toml.py | 11 +
task-sdk/pyproject.toml | 6 +
task-sdk/src/airflow/sdk/api/client.py | 6 +
.../src/airflow/sdk/api/datamodels/_generated.py | 8 +
task-sdk/src/airflow/sdk/execution_time/comms.py | 24 ++
.../airflow/sdk/execution_time/sentry/__init__.py | 21 +-
.../sdk/execution_time/sentry/configured.py | 152 +++++++++++++
.../src/airflow/sdk/execution_time/sentry/noop.py | 51 +++++
.../src/airflow/sdk/execution_time/supervisor.py | 5 +
.../src/airflow/sdk/execution_time/task_runner.py | 12 +
.../tests/task_sdk/execution_time/test_sentry.py | 243 +++++++++++++++++++++
.../task_sdk/execution_time/test_supervisor.py | 33 +++
23 files changed, 690 insertions(+), 431 deletions(-)
delete mode 100644 airflow-core/src/airflow/sentry.py
delete mode 100644 airflow-core/tests/unit/core/test_sentry.py
copy
providers/keycloak/src/airflow/providers/keycloak/auth_manager/datamodels/token.py
=> task-sdk/src/airflow/sdk/execution_time/sentry/__init__.py (70%)
create mode 100644 task-sdk/src/airflow/sdk/execution_time/sentry/configured.py
create mode 100644 task-sdk/src/airflow/sdk/execution_time/sentry/noop.py
create mode 100644 task-sdk/tests/task_sdk/execution_time/test_sentry.py
