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 <[email protected]> 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" {
