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

   ### Apache Airflow Provider(s)
   
   amazon
   
   ### Versions of Apache Airflow Providers
   
   apache-airflow-providers-amazon 9.40.0rc2 (present since the provider move 
in #46590)
   
   ### Apache Airflow version
   
   3.4.0
   
   ### What happened?
   
   The coroutine wrapper of `provide_bucket_name` has a debug `print`:
   
   ```python
   async def wrapper(*args: Any, **kwargs: Any) -> Any:
       bound_args = await maybe_add_bucket_name(*args, **kwargs)
       print(f"invoking async function {func=}")
       return await func(*bound_args.args, **bound_args.kwargs)
   ```
   
   
https://github.com/apache/airflow/blob/main/providers/amazon/src/airflow/providers/amazon/aws/hooks/s3.py#L104
   
   Every call of `get_head_object_async`, `get_file_metadata_async` or 
`aload_bytes` writes `invoking async function func=<function S3Hook.… at 0x…>` 
to stdout, so it lands in task and triggerer logs.
   
   ### What you think should happen instead?
   
   No output; remove the line (or a `log.debug` if it is wanted).
   
   ### How to reproduce
   
   Call `await S3Hook(...).get_head_object_async(client, key, bucket_name)` and 
look at stdout / the task log.
   
   ### Are you willing to submit PR?
   
   - [x] Yes I am willing to submit a PR!
   


-- 
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