[Bug][Tempo] A team scope's pipeline adds every Tempo team as a scope and resets their scope config

Đã đóng
  • Có gì không ổn?
#9,318 0 bình luận 0 reaction 0 người được giao Xem trên GitHub

Maintainer thường phản hồi trong vòng 2 ngày

Một pull request liên quan đã được merge.

  • #9319 của @ShivamSharma43 — đã merge

Đánh giá

Độ khó
4/5
Thời gian dự kiến
3-5 ngày
Mức phù hợp với người mới
25/100
Loại issue
Lỗi
Độ rõ ràng
Đặc tả rõ ràng
Mức độ hoạt động
Đình trệ
Công nghệ
go
Lĩnh vực
data-engineering

Hướng nghiên cứu

Start with the Tempo tasks in backend/plugins/tempo/tasks, especially collect-teams and extract_teams, and compare their team scoping with the worklog collector. Use the reproduction described in the issue and the raw fixture e2e/raw_tables/_raw_tempo_api_teams.csv to verify behavior; done means running one team scope leaves other scopes and its scope config unchanged. A pull request is already open for this issue.

Do mô hình lập chỉ mục viết ra từ nội dung của issue.

Mô tả

Search before asking
  • I had searched in the issues and found no similar issues.
What happened

Running a blueprint with one Tempo team scope adds every team of the Tempo instance as a data scope of the connection, and resets the scope config of the team scopes.

The _tool_tempo_teams table is both the scope table (TempoTeam is the plugin's ToolLayerScope) and the output of the extract_teams subtask. In backend/plugins/tempo/tasks:

  • collect-teams calls GET /4/teams without a team filter, so it collects all teams of the instance, with connection-wide raw params {"ConnectionId":1,"TeamId":0} (the team id of the scope isn't set, unlike the worklog collector).
  • extract_teams turns every collected team into a TempoTeam with ScopeConfigId 0. Because the params are connection-wide, the extractor's batch save first deletes every _tool_tempo_teams row with those params (i.e. every team scope extracted before, for any blueprint of the connection) and re-inserts all teams.

Result after one pipeline run:

  1. Teams the user never selected show up under the connection's data scopes (GET /plugins/tempo/connections/1/scopes).
  2. The scope_config_id of the selected team scopes is overwritten with 0, so the scope config assignment is lost on every run.
  3. A team scope the user deletes from the connection comes back on the next run of any other team scope.

Reproduced on main (84e3707) with the plugin's e2e helper on PostgreSQL: with only team 71 in _tool_tempo_teams (scope_config_id = 3) and the raw rows of e2e/raw_tables/_raw_tempo_api_teams.csv (teams 17 and 71), running ExtractTeams with {ConnectionId: 1, TeamId: 71} leaves:

team_id=17 name="Abstract BE Team"        scope_config_id=0 params={"ConnectionId":1,"TeamId":0}
team_id=71 name="SmartShopper (RTL+WHS)"  scope_config_id=0 params={"ConnectionId":1,"TeamId":0}

Also, collect-teams is a stateful collector that sends updatedFrom on incremental runs, but GET /4/teams has no such parameter (the Tempo OpenAPI spec, https://apidocs.tempo.io/tempo-openapi.yaml, lists offset, limit, teamMembers, name and teamIds). So an incremental run fetches every team again and appends it to the raw table instead of replacing it.

What do you expect to happen

A team scope's pipeline only collects and extracts its own team. The other team scopes of the connection, and teams that were never selected, are left alone, and the team scope keeps its scope config.

How to reproduce
  1. Create a Tempo connection to an instance with several teams.
  2. Add one team (e.g. id 71) as a data scope, assign it a scope config, and add it to a blueprint.
  3. Run the blueprint.
  4. SELECT team_id, scope_config_id, _raw_data_params FROM _tool_tempo_teams WHERE connection_id = 1 lists every team of the instance, all with scope_config_id = 0; the connection's data scope list in config-ui shows all of them.
Anything else

Proposed fix (I have a PR ready):

  • Scope the team raw data and the extracted rows per team ({ConnectionId, TeamId}, like TempoTeam.ScopeParams() and the worklog collector), so extracting one team scope only replaces its own row.
  • collect-teams: request only the scope's team with teamIds, drop the unsupported updatedFrom and use a plain (non-incremental) collector so each run refreshes the raw rows.
  • extract_teams: skip teams other than the scope's team and keep the existing scope_config_id.
  • Unit tests and an e2e test.

Related: #9284 (team summary longer than 255 characters). Since every team of the instance is extracted today, one long summary on any team can break extract_teams for every team scope of the connection.

Version

main

Are you willing to submit PR?
  • Yes I am willing to submit a PR!
Code of Conduct
Ngôn ngữ chính
Go
Star
3.2k
Fork
832
Merge trung bình
2 ngày 6 giờ
Pull request đã merge (30 ngày)
86

Chuẩn bị môi trường

Mở trong Codespaces

Khởi chạy dev container của dự án ngay trên trình duyệt, bằng tài khoản GitHub của bạn.

  • Không có Dockerfile hay tệp Docker Compose
  • Có mẫu pull request
  • Không có hướng dẫn đóng góp

Bắt đầu từ đâu

  1. Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
  2. Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
  3. Fork repository và làm thay đổi trên một nhánh.
  4. Mở pull request có tham chiếu số hiệu của issue.

Issue khác của apache/devlake

Tất cả issue của apache/devlake

Issue tương tự

Thêm issue về Go

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.