Skip to content

Commit 69e4503

Browse files
zero3233-bdtaoyifan89Coda-bot
authored
[feat][backend]support feedback auto task (#311)
* refactor: [Coda] use enums for observability task models (LogID: 202510281859330100911150896701F6B) Co-Authored-By: Coda <[email protected]> * refactor: [Coda] switch task processor to entity type (LogID: 202510291603100100911150893728B9B) Co-Authored-By: Coda <[email protected]> * test: [Coda] add getNonFinalTaskInfos tests (LogID: 20251030122712010091115089880C81B) Co-Authored-By: Coda <[email protected]> * Refactor task. Change-Id: Ieb1b49ae6d6e5d977dbaa995609a60e703aaef0e * rename task processor. Change-Id: I02c6962c72671edeeefbc73a1429508bb8060962 * test: [Coda] 调整tracehub单测适配Processor接口 (LogID: 2025110511251301009111510418056FE) Co-Authored-By: Coda <[email protected]> * Refactor backfill. Change-Id: Ic3b28c4a0e28bc40884b7232cfc4bf77109ac601 * test: [Coda] align tracehub tests with domain types (LogID: 202511051517200100911151042161061) Co-Authored-By: Coda <[email protected]> * TraceHub refactor. Change-Id: I1aceb52234a41337f9ae3fc8ae47fd7d722ddeb4 * add topic proc * fix consumer * add SpanWithAnnotation proc * Make new task consumer public. Change-Id: Ibb38cfb316881aa0c287a10834afd9608fcce3fe * add wire * fix mq proc * add wire gen * fix time proc * add annotation proc * refactor scheduled task. Change-Id: I8af657662d6015e825c1345d41e518f931e01acd * fix idl * fix ut * fix ut * fix ut * fix ut * fix InsertAnnotations proc * fix status_check * add validateCreateTaskReq * add fillctx * fix fill ctx * delete useless code * add wire * fix ut * fix ut * fix ut * fix ut * fix ut * fix * fix ut * fix ut * fix ut * add debug log * add debug log * fix ut * fix callback ttl * fix ut * go fmt * fix * fix ut * add defer * Try fix. Change-Id: I6d7e83d1845f3186623e5adebfd0feba76fb8676 * Fix scheduled task. Change-Id: I5bdbefab41323d4727ebf0223ffa13209a3a03c9 * Add run at startup config. Change-Id: I2cbb63a8a7478f08d1e0d00b36e94af932a84b30 * Fix golint. Change-Id: Ibb4dd77a99bfc00caf90fed86c878de1783886d6 * fix callback ttl * add extra_info * fix GetFieldValue * add ut * go fmt --------- Co-authored-by: taoyifan89 <[email protected]> Co-authored-by: Coda <[email protected]>
1 parent 9ab4e70 commit 69e4503

File tree

87 files changed

+4841
-4114
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

87 files changed

+4841
-4114
lines changed

backend/api/api.go

Lines changed: 3 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

backend/kitex_gen/coze/loop/observability/domain/filter/filter.go

Lines changed: 114 additions & 7 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

backend/kitex_gen/coze/loop/observability/domain/filter/k-filter.go

Lines changed: 97 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

backend/kitex_gen/coze/loop/observability/trace/coze.loop.observability.trace.go

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

backend/modules/observability/application/convertor/filter.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,9 @@ func FilterFieldsDTO2DO(f *filter.FilterFields) *loop_span.FilterFields {
4040
if field.SubFilter != nil {
4141
fField.SubFilter = FilterFieldsDTO2DO(field.SubFilter)
4242
}
43+
if field.ExtraInfo != nil {
44+
fField.ExtraInfo = field.ExtraInfo
45+
}
4346
ret.FilterFields = append(ret.FilterFields, fField)
4447
}
4548
return ret
@@ -79,6 +82,9 @@ func FilterFieldsDO2DTO(f *loop_span.FilterFields) *filter.FilterFields {
7982
if field.SubFilter != nil {
8083
fField.SubFilter = FilterFieldsDO2DTO(field.SubFilter)
8184
}
85+
if field.ExtraInfo != nil {
86+
fField.ExtraInfo = field.ExtraInfo
87+
}
8288
ret.FilterFields = append(ret.FilterFields, fField)
8389
}
8490
return ret

0 commit comments

Comments
 (0)