dstandish commented on code in PR #68601:
URL: https://github.com/apache/airflow/pull/68601#discussion_r3429406099
##########
task-sdk/src/airflow/sdk/bases/resumablejobmixin.py:
##########
@@ -108,6 +108,12 @@ def execute_resumable(self, context: Context) -> Any:
an external system boundary.
"""
operator_tag = {"operator": type(self).__name__}
+ # The task is team-scoped in multi-team deployments; surface team_name
on the
+ # resumable_job metrics via the running task instance's stats tags
(omitted when
+ # not multi-team or the task has no team).
+ ti = context.get("ti")
+ if ti is not None and (team_name := ti.stats_tags.get("team_name")):
+ operator_tag["team_name"] = team_name
Review Comment:
nit: you could now rename operator_tag to be more general since now it's
holding more than the operator. e.g. "tags" or "stats_tags" or .... something
--
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]
