[GitHub] [airflow] josh-fell commented on issue #29238: S3CopyObjectOperator when used within a dynamically mapped task group will use entire list of dynamically mapped input within `s3_key` and `data`.

[via GitHub]

josh-fell commented on issue #29238:
URL: https://github.com/apache/airflow/issues/29238#issuecomment-1409161012

   It looks like the `str()` tranformation, and probably any transformation on 
the `XComArg` causes an issue (at least for this latest example):
   ```
       @task_group()
       def say_things(num):
   
           @task
           def turn_num_to_int(num):
               time.sleep(5)
               return num
   
           int_num = turn_num_to_int(num)
   
           t2 = BashOperator(
               task_id="t2",
               bash_command="echo $MY_NUM",
               env={"MY_NUM": int_num}
   ```
   Looking at an individual mapped index, the rendered value is what is 
expected:
   <img width="728" alt="image" 
src="https://user-images.githubusercontent.com/48934154/215568597-dcda35e5-c968-4d68-8b49-f0d89b18ce07.png";>
   However, using `str(int_num`) instead gives us the entire mapped outputs:
   <img width="676" alt="image" 
src="https://user-images.githubusercontent.com/48934154/215568934-ba8f778c-c0bc-4416-8800-07e66ed256b8.png";>
   


-- 
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: commits-unsubscr...@airflow.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org