josh-fell commented on issue #29238:
URL: https://github.com/apache/airflow/issues/29238#issuecomment-1408937877
@TJaniF Another variation, but what happens if you don't use `json.dumps()`
on the `XComArg` being passed and without the `.partial()` on the operator? The
manipulation of the `XComArg` _might_ be causing an oddity?
```py
@task_group()
def create_s3_files(num):
@task
def return_num_as_int(my_num):
return my_num
my_num_as_int = return_num_as_int(num)
write_to_s3 = S3CreateObjectOperator(
task_id="write_to_s3",
aws_conn_id=AWS_CONN_ID,
data="Hi",
replace=True,
s3_key=f"{MY_S3_BUCKET}/{my_num_as_int}.txt"
)
my_num_as_int >> write_to_s3
tg_object = create_s3_files.expand(num=[0,1,2,3,4,5])
```
--
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]
