This is an automated email from the ASF dual-hosted git repository.
dstandish pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 8338926f12 Add clarification about AWS Connection behaviour (#29341)
add 1b18a501fe Enable individual trigger logging (#27758)
No new revisions were added by this update.
Summary of changes:
airflow/api_connexion/endpoints/log_endpoint.py | 8 +-
airflow/cli/cli_parser.py | 1 +
airflow/cli/commands/task_command.py | 30 +-
airflow/cli/commands/triggerer_command.py | 29 +-
airflow/config_templates/config.yml | 18 +
airflow/config_templates/default_airflow.cfg | 11 +
.../example_time_delta_sensor_async.py | 2 +-
airflow/executors/base_executor.py | 3 +-
airflow/executors/celery_kubernetes_executor.py | 6 +-
airflow/executors/kubernetes_executor.py | 19 +-
airflow/executors/local_kubernetes_executor.py | 7 +-
airflow/jobs/base_job.py | 4 +-
airflow/jobs/local_task_job.py | 22 +-
airflow/jobs/triggerer_job.py | 282 ++++++++++++-
airflow/models/taskinstance.py | 46 ++-
airflow/models/trigger.py | 15 +-
.../amazon/aws/log/cloudwatch_task_handler.py | 3 +
.../providers/amazon/aws/log/s3_task_handler.py | 64 +--
.../providers/elasticsearch/log/es_task_handler.py | 10 +-
.../providers/google/cloud/log/gcs_task_handler.py | 97 +++--
.../google/cloud/log/stackdriver_task_handler.py | 50 ++-
.../microsoft/azure/log/wasb_task_handler.py | 78 +++-
airflow/task/task_runner/standard_task_runner.py | 5 +-
airflow/triggers/base.py | 13 +-
airflow/triggers/temporal.py | 13 +-
airflow/utils/log/file_task_handler.py | 354 ++++++++++------
airflow/utils/log/trigger_handler.py | 139 +++++++
airflow/utils/serve_logs.py | 8 +-
.../TabWithTooltip.tsx} | 36 +-
.../js/dag/details/taskInstance/Logs/utils.ts | 9 +-
.../templates/triggerer/triggerer-deployment.yaml | 39 +-
.../triggerer-networkpolicy.yaml} | 25 +-
...-serviceaccount.yaml => triggerer-service.yaml} | 26 +-
chart/values.schema.json | 51 +++
chart/values.yaml | 19 +-
.../logging-monitoring/logging-tasks.rst | 48 ++-
tests/api_connexion/endpoints/test_log_endpoint.py | 8 +-
tests/charts/test_basic_helm_chart.py | 36 +-
tests/charts/test_extra_env_env_from.py | 3 +-
tests/charts/test_rbac.py | 34 +-
tests/charts/test_triggerer.py | 39 +-
tests/executors/test_base_executor.py | 2 +-
tests/executors/test_celery_kubernetes_executor.py | 8 +-
tests/executors/test_kubernetes_executor.py | 19 +-
tests/executors/test_local_kubernetes_executor.py | 15 +-
tests/jobs/test_triggerer_job.py | 56 ++-
tests/jobs/test_triggerer_job_logging.py | 445 +++++++++++++++++++++
.../amazon/aws/log/test_cloudwatch_task_handler.py | 17 -
.../amazon/aws/log/test_s3_task_handler.py | 27 +-
.../google/cloud/log/test_gcs_task_handler.py | 40 +-
.../microsoft/azure/log/test_wasb_task_handler.py | 25 +-
tests/utils/log/test_log_reader.py | 85 ++--
tests/utils/test_log_handlers.py | 339 ++++++++++++++--
tests/www/views/test_views_tasks.py | 23 +-
54 files changed, 2286 insertions(+), 525 deletions(-)
create mode 100644 airflow/utils/log/trigger_handler.py
copy airflow/www/static/js/{dag/details/taskInstance/BackToTaskSummary.tsx =>
components/TabWithTooltip.tsx} (63%)
copy chart/templates/{scheduler/scheduler-networkpolicy.yaml =>
triggerer/triggerer-networkpolicy.yaml} (71%)
copy chart/templates/triggerer/{triggerer-serviceaccount.yaml =>
triggerer-service.yaml} (70%)
create mode 100644 tests/jobs/test_triggerer_job_logging.py
