wolvery opened a new issue, #55853:
URL: https://github.com/apache/airflow/issues/55853

   ### Apache Airflow version
   
   3.0.6
   
   ### If "Other Airflow 2 version" selected, which one?
   
   _No response_
   
   ### What happened?
   
   We've recently upgrade from 2.9.3 to 3.0.6, and we have seen that the 
task_instance_mutation_hook cluster policy function is no longer being loaded. 
   We are using the Helm Chart v1.18.0 pointing the function in the airflow 
local setting, like:
   ```python
     airflowLocalSettings: |-
       import os
       import re
       import hashlib
       import logging
       from copy import deepcopy
       from typing import Optional, Any, Dict
       from airflow.models import TaskInstance
       from kubernetes.client import models as k8s
       from airflow.configuration import conf
       from google.cloud.logging.handlers import StructuredLogHandler
       from airflow.config_templates.airflow_local_settings import (
           DEFAULT_LOGGING_CONFIG,
           BASE_LOG_FOLDER,
       )
       log = logging.getLogger(__name__)
       # -- AWO SECTION -- 
   
       def task_instance_mutation_hook(task_instance: TaskInstance):
           """Task Function: This changes the POD annotation."""
           print("task_mutation on")
   
   ```
   
   We don't see any print/log.
   We use this function to manipulate KPOs.
   
   ### What you think should happen instead?
   
   It should print the message inside of airflow task.
   
   ### How to reproduce
   
   We are using the Airflow 3.0.6 and Helm Chart v1.18.0.
   
   
   ### Operating System
   
   airflow:3.0.6 python 3.10 image
   
   ### Versions of Apache Airflow Providers
   
   _No response_
   
   ### Deployment
   
   Official Apache Airflow Helm Chart
   
   ### Deployment details
   
   _No response_
   
   ### Anything else?
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [x] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [x] I agree to follow this project's [Code of 
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to