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/06/03 07:36:33 UTC

[GitHub] [airflow] uranusjr commented on pull request #24085: Add example for dynamically mapped tasks

uranusjr commented on PR #24085:
URL: https://github.com/apache/airflow/pull/24085#issuecomment-1145679908

   Looks like the _test_ is wrong. MappedOperator instances are deserialised into MappedOperator, not SerializedBaseOperator. The test should be updated to
   
   ```python
   if serialized_task.is_mapped:
       assert isinstance(serialized_task, MappedOperator)
       assert isinstance(task, MappedOperator)
   else:
       assert isinstance(serialized_task, SerializedBaseOperator)
       assert isinstance(task, BaseOperator)
   assert not isinstance(task, SerializedBaseOperator)
   ```


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