You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@devlake.apache.org by ly...@apache.org on 2024/10/30 07:45:39 UTC
(incubator-devlake) branch dev-1030 created (now d5cc70d5b)
This is an automated email from the ASF dual-hosted git repository.
lynwee pushed a change to branch dev-1030
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git
at d5cc70d5b feat(tapd): add more log when converting unicode
This branch includes the following new commits:
new d5cc70d5b feat(tapd): add more log when converting unicode
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(incubator-devlake) 01/01: feat(tapd): add more log when converting unicode
Posted by ly...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lynwee pushed a commit to branch dev-1030
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git
commit d5cc70d5bb630e8c07320cfa7599a09418ff4685
Author: d4x1 <15...@qq.com>
AuthorDate: Wed Oct 30 15:45:24 2024 +0800
feat(tapd): add more log when converting unicode
---
backend/plugins/tapd/tasks/bug_changelog_extractor.go | 4 ++++
backend/plugins/tapd/tasks/story_changelog_extractor.go | 3 +++
backend/plugins/tapd/tasks/task_changelog_extractor.go | 3 +++
3 files changed, 10 insertions(+)
diff --git a/backend/plugins/tapd/tasks/bug_changelog_extractor.go b/backend/plugins/tapd/tasks/bug_changelog_extractor.go
index e50d2b442..d96f682ab 100644
--- a/backend/plugins/tapd/tasks/bug_changelog_extractor.go
+++ b/backend/plugins/tapd/tasks/bug_changelog_extractor.go
@@ -38,6 +38,7 @@ var ExtractBugChangelogMeta = plugin.SubTaskMeta{
func ExtractBugChangelog(taskCtx plugin.SubTaskContext) errors.Error {
rawDataSubTaskArgs, data := CreateRawDataSubTaskArgs(taskCtx, RAW_BUG_CHANGELOG_TABLE)
+ logger := taskCtx.GetLogger()
extractor, err := api.NewApiExtractor(api.ApiExtractorArgs{
RawDataSubTaskArgs: *rawDataSubTaskArgs,
Extract: func(row *api.RawData) ([]interface{}, errors.Error) {
@@ -47,6 +48,7 @@ func ExtractBugChangelog(taskCtx plugin.SubTaskContext) errors.Error {
}
err := errors.Convert(json.Unmarshal(row.Data, &bugChangelogBody))
if err != nil {
+ logger.Error(err, "unmarshal: %s, err: %s", row.Data, err)
return nil, err
}
bugChangelog := bugChangelogBody.BugChange
@@ -62,11 +64,13 @@ func ExtractBugChangelog(taskCtx plugin.SubTaskContext) errors.Error {
}
err = convertUnicode(item)
if err != nil {
+ logger.Error(err, "convert unicode: %s, err: %s", item, err)
return nil, err
}
if item.Field == "iteration_id" {
iterationFrom, iterationTo, err := parseIterationChangelog(taskCtx, item.ValueBeforeParsed, item.ValueAfterParsed)
if err != nil {
+ logger.Error(err, "parseIterationChangelog: %s, err: %s", item, err)
return nil, err
}
item.IterationIdFrom = iterationFrom
diff --git a/backend/plugins/tapd/tasks/story_changelog_extractor.go b/backend/plugins/tapd/tasks/story_changelog_extractor.go
index 62c09ea72..fc86e61c0 100644
--- a/backend/plugins/tapd/tasks/story_changelog_extractor.go
+++ b/backend/plugins/tapd/tasks/story_changelog_extractor.go
@@ -36,6 +36,7 @@ var ExtractStoryChangelogMeta = plugin.SubTaskMeta{
}
func ExtractStoryChangelog(taskCtx plugin.SubTaskContext) errors.Error {
+ logger := taskCtx.GetLogger()
rawDataSubTaskArgs, data := CreateRawDataSubTaskArgs(taskCtx, RAW_STORY_CHANGELOG_TABLE)
extractor, err := api.NewApiExtractor(api.ApiExtractorArgs{
RawDataSubTaskArgs: *rawDataSubTaskArgs,
@@ -89,6 +90,7 @@ func ExtractStoryChangelog(taskCtx plugin.SubTaskContext) errors.Error {
}
err = convertUnicode(&item)
if err != nil {
+ logger.Error(err, "convert unicode: %s, err: %s", item, err)
return nil, err
}
results = append(results, &item)
@@ -103,6 +105,7 @@ func ExtractStoryChangelog(taskCtx plugin.SubTaskContext) errors.Error {
}
err = convertUnicode(&item)
if err != nil {
+ logger.Error(err, "convert unicode: %s, err: %s", item, err)
return nil, err
}
if item.Field == "iteration_id" {
diff --git a/backend/plugins/tapd/tasks/task_changelog_extractor.go b/backend/plugins/tapd/tasks/task_changelog_extractor.go
index 1ccfd1479..fde21f45b 100644
--- a/backend/plugins/tapd/tasks/task_changelog_extractor.go
+++ b/backend/plugins/tapd/tasks/task_changelog_extractor.go
@@ -38,6 +38,7 @@ var ExtractTaskChangelogMeta = plugin.SubTaskMeta{
func ExtractTaskChangelog(taskCtx plugin.SubTaskContext) errors.Error {
rawDataSubTaskArgs, data := CreateRawDataSubTaskArgs(taskCtx, RAW_TASK_CHANGELOG_TABLE)
+ logger := taskCtx.GetLogger()
extractor, err := api.NewApiExtractor(api.ApiExtractorArgs{
RawDataSubTaskArgs: *rawDataSubTaskArgs,
Extract: func(row *api.RawData) ([]interface{}, errors.Error) {
@@ -92,6 +93,7 @@ func ExtractTaskChangelog(taskCtx plugin.SubTaskContext) errors.Error {
}
err = convertUnicode(&item)
if err != nil {
+ logger.Error(err, "convert unicode: %s, err: %s", item, err)
return nil, err
}
default:
@@ -103,6 +105,7 @@ func ExtractTaskChangelog(taskCtx plugin.SubTaskContext) errors.Error {
}
err = convertUnicode(&item)
if err != nil {
+ logger.Error(err, "convert unicode: %s, err: %s", item, err)
return nil, err
}
if item.Field == "iteration_id" {