You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by GitBox <gi...@apache.org> on 2022/04/07 14:21:55 UTC

[GitHub] [airflow] ashb opened a new issue, #22833: Allow mapped Task as input to another mapped task

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

   This dag
   
   ```python
   with DAG(dag_id="simple_mapping", start_date=pendulum.DateTime(2022, 4, 6), catchup=True) as d3:
       @task(email='a@b.com')
       def add_one(x: int):
         return x + 1
   
       two_three_four = add_one.expand(x=[1, 2, 3])
       three_four_five = add_one.expand(x=one_two_three)
   ```
   
   Fails with this error:
   
   ```
     File "/home/ash/code/airflow/airflow/airflow/models/taskinstance.py", line 2239, in _record_task_map_for_downstreams
       raise UnmappableXComTypePushed(value)
   airflow.exceptions.UnmappableXComTypePushed: unmappable return type 'int'
   ```


-- 
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-unsubscribe@airflow.apache.org.apache.org

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

[GitHub] [airflow] ashb commented on issue #22833: Allow mapped Task as input to another mapped task

Posted by GitBox <gi...@apache.org>.
ashb commented on issue #22833:
URL: https://github.com/apache/airflow/issues/22833#issuecomment-1091886629

   Whoops, yes. It's right now.


-- 
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-unsubscribe@airflow.apache.org

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

[GitHub] [airflow] uranusjr commented on issue #22833: Allow mapped Task as input to another mapped task

Posted by GitBox <gi...@apache.org>.
uranusjr commented on issue #22833:
URL: https://github.com/apache/airflow/issues/22833#issuecomment-1091883656

   (I edited the example code to add what I think `one_two_three` should look like, for clarity.)


-- 
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-unsubscribe@airflow.apache.org

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

[GitHub] [airflow] ashb closed issue #22833: Allow mapped Task as input to another mapped task

Posted by GitBox <gi...@apache.org>.
ashb closed issue #22833: Allow mapped Task as input to another mapped task
URL: https://github.com/apache/airflow/issues/22833


-- 
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-unsubscribe@airflow.apache.org

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