[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r786430565 ## File path: airflow/models/baseoperator.py ## @@ -207,6 +207,7 @@ def apply_defaults(self: "BaseOperator", *args: Any, **kwargs: Any) -> Any:

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r786204849 ## File path: airflow/models/baseoperator.py ## @@ -1706,25 +1701,49 @@ def _validate_kwarg_names_for_mapping(cls: Type[BaseOperator], func_name:

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r786202050 ## File path: airflow/models/baseoperator.py ## @@ -136,6 +136,7 @@ def _apply_defaults(cls, func: T) -> T: non_optional_args = {

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r786202050 ## File path: airflow/models/baseoperator.py ## @@ -136,6 +136,7 @@ def _apply_defaults(cls, func: T) -> T: non_optional_args = {

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r786181173 ## File path: airflow/serialization/serialized_objects.py ## @@ -653,10 +677,14 @@ def deserialize_operator(cls, encoded_op: Dict[str, Any]) ->

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r786165855 ## File path: airflow/serialization/serialized_objects.py ## @@ -653,10 +677,14 @@ def deserialize_operator(cls, encoded_op: Dict[str, Any]) ->

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r786165206 ## File path: airflow/models/baseoperator.py ## @@ -207,6 +207,7 @@ def apply_defaults(self: "BaseOperator", *args: Any, **kwargs: Any) -> Any:

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r785711324 ## File path: airflow/serialization/serialized_objects.py ## @@ -653,10 +677,14 @@ def deserialize_operator(cls, encoded_op: Dict[str, Any]) ->

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r785706252 ## File path: airflow/models/baseoperator.py ## @@ -207,6 +207,7 @@ def apply_defaults(self: "BaseOperator", *args: Any, **kwargs: Any) -> Any:

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r783623735 ## File path: airflow/models/baseoperator.py ## @@ -207,6 +207,7 @@ def apply_defaults(self: "BaseOperator", *args: Any, **kwargs: Any) -> Any:

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r781930519 ## File path: airflow/models/baseoperator.py ## @@ -207,6 +207,7 @@ def apply_defaults(self: "BaseOperator", *args: Any, **kwargs: Any) -> Any:

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r781930519 ## File path: airflow/models/baseoperator.py ## @@ -207,6 +207,7 @@ def apply_defaults(self: "BaseOperator", *args: Any, **kwargs: Any) -> Any:

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r781911926 ## File path: airflow/models/baseoperator.py ## @@ -1634,7 +1635,7 @@ def map(self, **kwargs) -> "MappedOperator": def

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r780938792 ## File path: airflow/serialization/serialized_objects.py ## @@ -623,7 +647,7 @@ def deserialize_operator(cls, encoded_op: Dict[str, Any]) ->

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r780893173 ## File path: airflow/models/baseoperator.py ## @@ -1634,7 +1635,7 @@ def map(self, **kwargs) -> "MappedOperator": def

[GitHub] [airflow] uranusjr commented on a change in pull request #20743: Serialize mapped tasks and task groups

uranusjr commented on a change in pull request #20743: URL: https://github.com/apache/airflow/pull/20743#discussion_r780892938 ## File path: airflow/models/baseoperator.py ## @@ -1634,7 +1635,7 @@ def map(self, **kwargs) -> "MappedOperator": def