[GitHub] [airflow] uranusjr commented on a diff in pull request #22975: Resolve XComArg's before trying to unmap MappedOperators

Wed, 13 Apr 2022 10:28:14 -0700 


uranusjr commented on code in PR #22975:
URL: https://github.com/apache/airflow/pull/22975#discussion_r849728476


##########
airflow/models/xcom_arg.py:
##########
@@ -136,12 +139,15 @@ def set_downstream(
         """Proxy to underlying operator set_downstream method. Required by 
TaskMixin."""
         self.operator.set_downstream(task_or_task_list, edge_modifier)
 
-    def resolve(self, context: Context) -> Any:
+    @provide_session
+    def resolve(self, context: Context, session: "Session" = NEW_SESSION) -> 
Any:

Review Comment:
   Don’t quite remember now, maybe it has something to do with DagParam also 
has `resolve`. I guess we can do it and see what happens.



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

Reply via email to