Skip to content

Commit

Permalink
Apply suggestions from code review
Browse files Browse the repository at this point in the history
  • Loading branch information
ephraimbuddy committed Jun 21, 2023
1 parent db79d2a commit d8c43db
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion airflow/models/xcom_arg.py
Original file line number Diff line number Diff line change
Expand Up @@ -370,7 +370,7 @@ def resolve(self, context: Context, session: Session = NEW_SESSION) -> Any:
return result
if self.key == XCOM_RETURN_KEY:
return None
if self.operator.multiple_outputs: # type: ignore
if getattr(self.operator, "multiple_outputs", False):
# If the operator is set to have multiple outputs and it was not executed,
# we should return "None" instead of showing an error. This is because when
# multiple outputs XComs are created, the XCom keys associated with them will have
Expand Down

0 comments on commit d8c43db

Please sign in to comment.