uranusjr commented on a change in pull request #20945:
URL: https://github.com/apache/airflow/pull/20945#discussion_r788943492
##########
File path: airflow/models/baseoperator.py
##########
@@ -1874,6 +1794,34 @@ def get_serialized_fields(cls):
)
return cls.__serialized_fields
+ @property
+ def params(self) -> Union[dict, ParamsDict]:
+ return self.partial_kwargs.get("params", ParamsDict())
+
+ @property
+ def queue(self) -> str:
+ return self.partial_kwargs.get("queue", DEFAULT_QUEUE)
Review comment:
We need _some_ value on the unmapped TI since `queue` (and other
calculated properties listed here) is recorded when the (unmapped) TI is
created. We can still implement mapping support by using a different value when
we create the mapped TIs, but we still need this so the unmapped TI has
something to store in the db.
--
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]
