alexInhert opened a new issue #18253:
URL: https://github.com/apache/airflow/issues/18253
### Description
Airflow offers Task policies.
The problem is that while task policy alter the task and replace parameters
there is no way to indicate to the user that parameters were switched.
### Use case/motivation
Consider the following:
```
def task_policy(task: BaseOperator):
if task.timeout > timedelta(hours=10):
task.timeout = timedelta(hours=10)
```
This replace the timeout for task if criteria met. However the problem is
that if you set timeout 20 hours in your code this is what you will see in task
instance details. You won't see 10 you will see 20.
Also if I do:
```
def task_policy(task: BaseOperator):
if task.timeout > timedelta(hours=10):
task.timeout = timedelta(hours=10)
self.log("task policy changed timeout to 10 hours")
```
This log will be printed in the web server log! it will not be printed in
the task log.
Result: the user who set timeout of 20 hours and the task timouted after 10
has no idea why it happened. He can't see it in the logs, he can't see it in
task details. he is completely clueless.
Desired solution - allow to write to the task log from the task policy and
if possible indicate in the task instance that a policy applied on the task and
changed values.
### Related issues
no
### Are you willing to submit a PR?
- [ ] 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]
