zach-overflow commented on code in PR #62782:
URL: https://github.com/apache/airflow/pull/62782#discussion_r2879169623
##########
task-sdk/src/airflow/sdk/execution_time/execute_workload.py:
##########
@@ -53,7 +53,13 @@ def execute_workload(workload: ExecuteTask) -> None:
if not isinstance(workload, workloads.ExecuteTask):
raise ValueError(f"Executor does not know how to handle
{type(workload)}")
- log.info("Executing workload", workload=workload)
+ log.info(
Review Comment:
You could keep the same logging statement here and instead set the
JWT-containing attribute as a `pydantic.SecretStr`, which will by default
redact the field from logs.
--
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]
