ferruzzi commented on code in PR #68601:
URL: https://github.com/apache/airflow/pull/68601#discussion_r3429899752
##########
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:
Actually, that's totally fair. I saw a mix of "stats_tags" and
"metrics_tags" while I was going through this, I'll use one of those
--
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]
