You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@devlake.apache.org by wa...@apache.org on 2022/07/18 03:12:29 UTC

[incubator-devlake] 01/02: fix: fill in core.SubTaskMeta.DomainTypes

This is an automated email from the ASF dual-hosted git repository.

warren pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git

commit a2e5de3701f46b6eac205204f9e6ba2134b299d4
Author: zhangliang <li...@merico.dev>
AuthorDate: Fri Jul 15 21:58:46 2022 +0800

    fix: fill in core.SubTaskMeta.DomainTypes
---
 plugins/ae/tasks/commits_collector.go                   | 1 +
 plugins/ae/tasks/commits_convertor.go                   | 1 +
 plugins/ae/tasks/commits_extractor.go                   | 1 +
 plugins/ae/tasks/project_collector.go                   | 1 +
 plugins/ae/tasks/project_extractor.go                   | 1 +
 plugins/core/plugin_task.go                             | 1 +
 plugins/gitee/tasks/account_convertor.go                | 3 ++-
 plugins/gitee/tasks/commit_collector.go                 | 1 +
 plugins/gitee/tasks/commit_convertor.go                 | 1 +
 plugins/gitee/tasks/commit_extractor.go                 | 1 +
 plugins/gitee/tasks/commit_stats_collector.go           | 1 +
 plugins/gitee/tasks/commit_stats_extractor.go           | 1 +
 plugins/gitee/tasks/issue_collector.go                  | 1 +
 plugins/gitee/tasks/issue_comment_collector.go          | 1 +
 plugins/gitee/tasks/issue_comment_convertor.go          | 1 +
 plugins/gitee/tasks/issue_comment_extractor.go          | 1 +
 plugins/gitee/tasks/issue_convertor.go                  | 1 +
 plugins/gitee/tasks/issue_extractor.go                  | 1 +
 plugins/gitee/tasks/issue_label_convertor.go            | 1 +
 plugins/gitee/tasks/pr_collector.go                     | 1 +
 plugins/gitee/tasks/pr_comment_convertor.go             | 1 +
 plugins/gitee/tasks/pr_commit_collector.go              | 1 +
 plugins/gitee/tasks/pr_commit_convertor.go              | 1 +
 plugins/gitee/tasks/pr_commit_extractor.go              | 1 +
 plugins/gitee/tasks/pr_convertor.go                     | 1 +
 plugins/gitee/tasks/pr_extractor.go                     | 1 +
 plugins/gitee/tasks/pr_issue_convertor.go               | 1 +
 plugins/gitee/tasks/pr_issue_enricher.go                | 1 +
 plugins/gitee/tasks/pr_label_convertor.go               | 1 +
 plugins/gitee/tasks/pr_review_collector.go              | 1 +
 plugins/gitee/tasks/pr_review_extractor.go              | 1 +
 plugins/gitee/tasks/repo_collector.go                   | 1 +
 plugins/gitee/tasks/repo_convertor.go                   | 1 +
 plugins/gitee/tasks/repo_extractor.go                   | 1 +
 plugins/gitextractor/tasks/git_repo_collector.go        | 3 +++
 plugins/github/tasks/account_collector.go               | 2 +-
 plugins/github/tasks/account_convertor.go               | 2 +-
 plugins/github/tasks/account_extractor.go               | 2 +-
 plugins/github/tasks/comment_collector.go               | 2 +-
 plugins/github/tasks/comment_extractor.go               | 2 +-
 plugins/github/tasks/milestone_collector.go             | 1 +
 plugins/github/tasks/milestone_converter.go             | 1 +
 plugins/github/tasks/milestone_extractor.go             | 1 +
 plugins/github/tasks/pr_collector.go                    | 2 +-
 plugins/github/tasks/pr_comment_convertor.go            | 2 +-
 plugins/github/tasks/pr_commit_collector.go             | 2 +-
 plugins/github/tasks/pr_commit_convertor.go             | 2 +-
 plugins/github/tasks/pr_commit_extractor.go             | 2 +-
 plugins/github/tasks/pr_convertor.go                    | 2 +-
 plugins/github/tasks/pr_extractor.go                    | 2 +-
 plugins/github/tasks/pr_issue_convertor.go              | 2 +-
 plugins/github/tasks/pr_issue_enricher.go               | 2 +-
 plugins/github/tasks/pr_label_convertor.go              | 2 +-
 plugins/github/tasks/pr_review_collector.go             | 2 +-
 plugins/github/tasks/pr_review_extractor.go             | 2 +-
 plugins/github/tasks/repo_collector.go                  | 2 +-
 plugins/github/tasks/repo_convertor.go                  | 2 +-
 plugins/github/tasks/repo_extractor.go                  | 2 +-
 plugins/gitlab/tasks/account_collector.go               | 1 +
 plugins/gitlab/tasks/account_extractor.go               | 1 +
 plugins/gitlab/tasks/mr_collector.go                    | 2 +-
 plugins/gitlab/tasks/mr_comment_convertor.go            | 2 +-
 plugins/gitlab/tasks/mr_commit_collector.go             | 2 +-
 plugins/gitlab/tasks/mr_commit_convertor.go             | 2 +-
 plugins/gitlab/tasks/mr_commit_extractor.go             | 2 +-
 plugins/gitlab/tasks/mr_convertor.go                    | 2 +-
 plugins/gitlab/tasks/mr_enricher.go                     | 2 +-
 plugins/gitlab/tasks/mr_extractor.go                    | 2 +-
 plugins/gitlab/tasks/mr_label_convertor.go              | 2 +-
 plugins/gitlab/tasks/mr_note_collector.go               | 2 +-
 plugins/gitlab/tasks/mr_note_extractor.go               | 2 +-
 plugins/gitlab/tasks/note_convertor.go                  | 2 +-
 plugins/gitlab/tasks/pipeline_collector.go              | 2 +-
 plugins/gitlab/tasks/pipeline_extractor.go              | 2 +-
 plugins/gitlab/tasks/project_collector.go               | 2 +-
 plugins/gitlab/tasks/project_convertor.go               | 2 +-
 plugins/gitlab/tasks/project_extractor.go               | 2 +-
 plugins/jira/tasks/issue_changelog_collector.go         | 2 +-
 plugins/jira/tasks/issue_changelog_convertor.go         | 2 +-
 plugins/jira/tasks/issue_changelog_extractor.go         | 2 +-
 plugins/jira/tasks/issue_collector.go                   | 2 +-
 plugins/jira/tasks/issue_commit_convertor.go            | 2 +-
 plugins/jira/tasks/issue_extractor.go                   | 2 +-
 plugins/refdiff/tasks/ref_commit_diff_calculator.go     | 1 +
 plugins/refdiff/tasks/ref_issue_diff_calculator.go      | 1 +
 plugins/refdiff/tasks/refs_pr_cherry_pick_calculator.go | 1 +
 plugins/tapd/tasks/account_collector.go                 | 1 +
 plugins/tapd/tasks/account_converter.go                 | 1 +
 plugins/tapd/tasks/account_extractor.go                 | 1 +
 plugins/tapd/tasks/bug_changelog_collector.go           | 1 +
 plugins/tapd/tasks/bug_changelog_converter.go           | 1 +
 plugins/tapd/tasks/bug_changelog_extractor.go           | 1 +
 plugins/tapd/tasks/bug_collector.go                     | 1 +
 plugins/tapd/tasks/bug_commit_collector.go              | 1 +
 plugins/tapd/tasks/bug_commit_converter.go              | 1 +
 plugins/tapd/tasks/bug_commit_extractor.go              | 1 +
 plugins/tapd/tasks/bug_converter.go                     | 1 +
 plugins/tapd/tasks/bug_custom_fields_collector.go       | 1 +
 plugins/tapd/tasks/bug_custom_fields_extractor.go       | 1 +
 plugins/tapd/tasks/bug_extractor.go                     | 1 +
 plugins/tapd/tasks/bug_label_convertor.go               | 1 +
 plugins/tapd/tasks/bug_status_collector.go              | 1 +
 plugins/tapd/tasks/bug_status_extractor.go              | 1 +
 plugins/tapd/tasks/company_collector.go                 | 1 +
 plugins/tapd/tasks/company_extractor.go                 | 1 +
 plugins/tapd/tasks/iteration_collector.go               | 1 +
 plugins/tapd/tasks/iteration_converter.go               | 1 +
 plugins/tapd/tasks/iteration_extractor.go               | 1 +
 plugins/tapd/tasks/story_bug_collector.go               | 1 +
 plugins/tapd/tasks/story_bug_extractor.go               | 1 +
 plugins/tapd/tasks/story_category_collector.go          | 1 +
 plugins/tapd/tasks/story_category_extractor.go          | 1 +
 plugins/tapd/tasks/story_changelog_collector.go         | 1 +
 plugins/tapd/tasks/story_changelog_converter.go         | 1 +
 plugins/tapd/tasks/story_changelog_extractor.go         | 1 +
 plugins/tapd/tasks/story_collector.go                   | 1 +
 plugins/tapd/tasks/story_commit_collector.go            | 1 +
 plugins/tapd/tasks/story_commit_converter.go            | 1 +
 plugins/tapd/tasks/story_commit_extractor.go            | 1 +
 plugins/tapd/tasks/story_converter.go                   | 1 +
 plugins/tapd/tasks/story_custom_fields_collector.go     | 1 +
 plugins/tapd/tasks/story_custom_fields_extractor.go     | 1 +
 plugins/tapd/tasks/story_extractor.go                   | 1 +
 plugins/tapd/tasks/story_label_convertor.go             | 1 +
 plugins/tapd/tasks/story_status_collector.go            | 1 +
 plugins/tapd/tasks/story_status_extractor.go            | 1 +
 plugins/tapd/tasks/sub_workspace_collector.go           | 1 +
 plugins/tapd/tasks/sub_workspace_converter.go           | 1 +
 plugins/tapd/tasks/sub_workspace_extractor.go           | 1 +
 plugins/tapd/tasks/task_changelog_collector.go          | 1 +
 plugins/tapd/tasks/task_changelog_converter.go          | 1 +
 plugins/tapd/tasks/task_changelog_extractor.go          | 1 +
 plugins/tapd/tasks/task_collector.go                    | 1 +
 plugins/tapd/tasks/task_commit_collector.go             | 1 +
 plugins/tapd/tasks/task_commit_converter.go             | 1 +
 plugins/tapd/tasks/task_commit_extractor.go             | 1 +
 plugins/tapd/tasks/task_converter.go                    | 1 +
 plugins/tapd/tasks/task_custom_fields_collector.go      | 1 +
 plugins/tapd/tasks/task_custom_fields_extractor.go      | 1 +
 plugins/tapd/tasks/task_extractor.go                    | 1 +
 plugins/tapd/tasks/task_label_convertor.go              | 1 +
 plugins/tapd/tasks/worklog_collector.go                 | 1 +
 plugins/tapd/tasks/worklog_converter.go                 | 1 +
 plugins/tapd/tasks/worklog_extractor.go                 | 1 +
 144 files changed, 147 insertions(+), 44 deletions(-)

diff --git a/plugins/ae/tasks/commits_collector.go b/plugins/ae/tasks/commits_collector.go
index a1b598cf..3df2ef29 100644
--- a/plugins/ae/tasks/commits_collector.go
+++ b/plugins/ae/tasks/commits_collector.go
@@ -72,4 +72,5 @@ var CollectCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectCommits,
 	EnabledByDefault: true,
 	Description:      "Collect commit analysis data from AE api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
diff --git a/plugins/ae/tasks/commits_convertor.go b/plugins/ae/tasks/commits_convertor.go
index 53e216ca..3938835c 100644
--- a/plugins/ae/tasks/commits_convertor.go
+++ b/plugins/ae/tasks/commits_convertor.go
@@ -74,4 +74,5 @@ var ConvertCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertCommits,
 	EnabledByDefault: true,
 	Description:      "Update domain layer commits dev_eq field according to ae_commits",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
diff --git a/plugins/ae/tasks/commits_extractor.go b/plugins/ae/tasks/commits_extractor.go
index a627dcba..403fd422 100644
--- a/plugins/ae/tasks/commits_extractor.go
+++ b/plugins/ae/tasks/commits_extractor.go
@@ -76,4 +76,5 @@ var ExtractCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractCommits,
 	EnabledByDefault: true,
 	Description:      "Extract raw commit data into tool layer table ae_commits",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
diff --git a/plugins/ae/tasks/project_collector.go b/plugins/ae/tasks/project_collector.go
index a8454764..7a4c8fbe 100644
--- a/plugins/ae/tasks/project_collector.go
+++ b/plugins/ae/tasks/project_collector.go
@@ -64,4 +64,5 @@ var CollectProjectMeta = core.SubTaskMeta{
 	EntryPoint:       CollectProject,
 	EnabledByDefault: true,
 	Description:      "Collect analysis project data from AE api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/ae/tasks/project_extractor.go b/plugins/ae/tasks/project_extractor.go
index 7627ab27..b1ac02fa 100644
--- a/plugins/ae/tasks/project_extractor.go
+++ b/plugins/ae/tasks/project_extractor.go
@@ -78,4 +78,5 @@ var ExtractProjectMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractProject,
 	EnabledByDefault: true,
 	Description:      "Extract raw project data into tool layer table ae_projects",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/core/plugin_task.go b/plugins/core/plugin_task.go
index dc4ee2ef..a878c880 100644
--- a/plugins/core/plugin_task.go
+++ b/plugins/core/plugin_task.go
@@ -85,6 +85,7 @@ const DOMAIN_TYPE_CODE = "CODE"
 const DOMAIN_TYPE_TICKET = "TICKET"
 const DOMAIN_TYPE_CICD = "CICD"
 const DOMAIN_TYPE_CROSS = "CROSS"
+const DOMAIN_TYPE_CODE_REVIEW = "CODEREVIEW"
 
 var DOMAIN_TYPES = []string{
 	DOMAIN_TYPE_CODE,
diff --git a/plugins/gitee/tasks/account_convertor.go b/plugins/gitee/tasks/account_convertor.go
index 7dbee3ed..43d03a97 100644
--- a/plugins/gitee/tasks/account_convertor.go
+++ b/plugins/gitee/tasks/account_convertor.go
@@ -34,7 +34,8 @@ var ConvertAccountsMeta = core.SubTaskMeta{
 	Name:             "convertAccounts",
 	EntryPoint:       ConvertAccounts,
 	EnabledByDefault: true,
-	Description:      "Convert tool layer table gitee_accountss into  domain layer table accountss",
+	Description:      "Convert tool layer table gitee_accounts into  domain layer table accounts",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ConvertAccounts(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/commit_collector.go b/plugins/gitee/tasks/commit_collector.go
index cded9309..b6d86dee 100644
--- a/plugins/gitee/tasks/commit_collector.go
+++ b/plugins/gitee/tasks/commit_collector.go
@@ -36,6 +36,7 @@ var CollectCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiCommits,
 	EnabledByDefault: true,
 	Description:      "Collect commit data from gitee api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE, core.DOMAIN_TYPE_CROSS},
 }
 
 func CollectApiCommits(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/commit_convertor.go b/plugins/gitee/tasks/commit_convertor.go
index eeaecf29..dcca8fc2 100644
--- a/plugins/gitee/tasks/commit_convertor.go
+++ b/plugins/gitee/tasks/commit_convertor.go
@@ -34,6 +34,7 @@ var ConvertCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertCommits,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table gitee_commits into  domain layer table commits",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE, core.DOMAIN_TYPE_CROSS},
 }
 
 func ConvertCommits(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/commit_extractor.go b/plugins/gitee/tasks/commit_extractor.go
index 65fe4325..bd584255 100644
--- a/plugins/gitee/tasks/commit_extractor.go
+++ b/plugins/gitee/tasks/commit_extractor.go
@@ -30,6 +30,7 @@ var ExtractCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiCommits,
 	EnabledByDefault: true,
 	Description:      "Extract raw commit data into tool layer table GiteeCommit,GiteeAccount and GiteeRepoCommit",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE, core.DOMAIN_TYPE_CROSS},
 }
 
 type GiteeCommit struct {
diff --git a/plugins/gitee/tasks/commit_stats_collector.go b/plugins/gitee/tasks/commit_stats_collector.go
index 29e4b61b..7afedd01 100644
--- a/plugins/gitee/tasks/commit_stats_collector.go
+++ b/plugins/gitee/tasks/commit_stats_collector.go
@@ -40,6 +40,7 @@ var CollectApiCommitStatsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiCommitStats,
 	EnabledByDefault: false,
 	Description:      "Collect commitStats data from Gitee api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
 
 func CollectApiCommitStats(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/commit_stats_extractor.go b/plugins/gitee/tasks/commit_stats_extractor.go
index 9c5f2b55..b9af9705 100644
--- a/plugins/gitee/tasks/commit_stats_extractor.go
+++ b/plugins/gitee/tasks/commit_stats_extractor.go
@@ -32,6 +32,7 @@ var ExtractApiCommitStatsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiCommitStats,
 	EnabledByDefault: false,
 	Description:      "Extract raw commit stats data into tool layer table gitee_commit_stats",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
 
 type ApiSingleCommitResponse struct {
diff --git a/plugins/gitee/tasks/issue_collector.go b/plugins/gitee/tasks/issue_collector.go
index 83c821f0..7b43e8d2 100644
--- a/plugins/gitee/tasks/issue_collector.go
+++ b/plugins/gitee/tasks/issue_collector.go
@@ -38,6 +38,7 @@ var CollectApiIssuesMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiIssues,
 	EnabledByDefault: true,
 	Description:      "Collect issues data from Gitee api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func CollectApiIssues(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/issue_comment_collector.go b/plugins/gitee/tasks/issue_comment_collector.go
index 124bec3b..acff7e49 100644
--- a/plugins/gitee/tasks/issue_comment_collector.go
+++ b/plugins/gitee/tasks/issue_comment_collector.go
@@ -35,6 +35,7 @@ var CollectApiIssueCommentsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiIssueComments,
 	EnabledByDefault: true,
 	Description:      "Collect comments data from Gitee api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func CollectApiIssueComments(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/issue_comment_convertor.go b/plugins/gitee/tasks/issue_comment_convertor.go
index e20ab3c7..8226008c 100644
--- a/plugins/gitee/tasks/issue_comment_convertor.go
+++ b/plugins/gitee/tasks/issue_comment_convertor.go
@@ -35,6 +35,7 @@ var ConvertIssueCommentsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertIssueComments,
 	EnabledByDefault: true,
 	Description:      "ConvertIssueComments data from Gitee api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ConvertIssueComments(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/issue_comment_extractor.go b/plugins/gitee/tasks/issue_comment_extractor.go
index 3caa6a46..24c46699 100644
--- a/plugins/gitee/tasks/issue_comment_extractor.go
+++ b/plugins/gitee/tasks/issue_comment_extractor.go
@@ -33,6 +33,7 @@ var ExtractApiIssueCommentsMeta = core.SubTaskMeta{
 	EnabledByDefault: true,
 	Description: "Extract raw comment data  into tool layer table gitee_pull_request_comments" +
 		"and gitee_issue_comments",
+	DomainTypes: []string{core.DOMAIN_TYPE_TICKET},
 }
 
 type IssueComment struct {
diff --git a/plugins/gitee/tasks/issue_convertor.go b/plugins/gitee/tasks/issue_convertor.go
index b30dfa64..acd76de1 100644
--- a/plugins/gitee/tasks/issue_convertor.go
+++ b/plugins/gitee/tasks/issue_convertor.go
@@ -36,6 +36,7 @@ var ConvertIssuesMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertIssues,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table gitee_issues into  domain layer table issues",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ConvertIssues(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/issue_extractor.go b/plugins/gitee/tasks/issue_extractor.go
index 7072afb2..b81a3657 100644
--- a/plugins/gitee/tasks/issue_extractor.go
+++ b/plugins/gitee/tasks/issue_extractor.go
@@ -34,6 +34,7 @@ var ExtractApiIssuesMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiIssues,
 	EnabledByDefault: true,
 	Description:      "Extract raw Issues data into tool layer table gitee_issues",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 type IssuesResponse struct {
diff --git a/plugins/gitee/tasks/issue_label_convertor.go b/plugins/gitee/tasks/issue_label_convertor.go
index 95ba664d..d4bb2109 100644
--- a/plugins/gitee/tasks/issue_label_convertor.go
+++ b/plugins/gitee/tasks/issue_label_convertor.go
@@ -34,6 +34,7 @@ var ConvertIssueLabelsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertIssueLabels,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table gitee_issue_labels into  domain layer table issue_labels",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ConvertIssueLabels(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/pr_collector.go b/plugins/gitee/tasks/pr_collector.go
index f22eb1f8..f4bbe20a 100644
--- a/plugins/gitee/tasks/pr_collector.go
+++ b/plugins/gitee/tasks/pr_collector.go
@@ -39,6 +39,7 @@ var CollectApiPullRequestsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiPullRequests,
 	EnabledByDefault: true,
 	Description:      "Collect PullRequests data from Gitee api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func CollectApiPullRequests(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/pr_comment_convertor.go b/plugins/gitee/tasks/pr_comment_convertor.go
index 4d76e034..ca8352d8 100644
--- a/plugins/gitee/tasks/pr_comment_convertor.go
+++ b/plugins/gitee/tasks/pr_comment_convertor.go
@@ -35,6 +35,7 @@ var ConvertPullRequestCommentsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertPullRequestComments,
 	EnabledByDefault: true,
 	Description:      "ConvertPullRequestComments data from Gitee api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertPullRequestComments(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/pr_commit_collector.go b/plugins/gitee/tasks/pr_commit_collector.go
index b82d5949..b6dde388 100644
--- a/plugins/gitee/tasks/pr_commit_collector.go
+++ b/plugins/gitee/tasks/pr_commit_collector.go
@@ -39,6 +39,7 @@ var CollectApiPullRequestCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiPullRequestCommits,
 	EnabledByDefault: true,
 	Description:      "Collect PullRequestCommits data from Gitee api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 type SimplePr struct {
diff --git a/plugins/gitee/tasks/pr_commit_convertor.go b/plugins/gitee/tasks/pr_commit_convertor.go
index 2a38b97b..d206d9fc 100644
--- a/plugins/gitee/tasks/pr_commit_convertor.go
+++ b/plugins/gitee/tasks/pr_commit_convertor.go
@@ -34,6 +34,7 @@ var ConvertPullRequestCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertPullRequestCommits,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table gitee_pull_request_commits into  domain layer table pull_request_commits",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertPullRequestCommits(taskCtx core.SubTaskContext) (err error) {
diff --git a/plugins/gitee/tasks/pr_commit_extractor.go b/plugins/gitee/tasks/pr_commit_extractor.go
index 0e7b8b68..9b9c95c8 100644
--- a/plugins/gitee/tasks/pr_commit_extractor.go
+++ b/plugins/gitee/tasks/pr_commit_extractor.go
@@ -31,6 +31,7 @@ var ExtractApiPullRequestCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiPullRequestCommits,
 	EnabledByDefault: true,
 	Description:      "Extract raw PullRequestCommits data into tool layer table gitee_commits",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 type PrCommitsResponse struct {
diff --git a/plugins/gitee/tasks/pr_convertor.go b/plugins/gitee/tasks/pr_convertor.go
index 711ce6b2..8ea6a787 100644
--- a/plugins/gitee/tasks/pr_convertor.go
+++ b/plugins/gitee/tasks/pr_convertor.go
@@ -35,6 +35,7 @@ var ConvertPullRequestsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertPullRequests,
 	EnabledByDefault: true,
 	Description:      "ConvertPullRequests data from Gitee api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertPullRequests(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/pr_extractor.go b/plugins/gitee/tasks/pr_extractor.go
index 097e9b09..19c7377a 100644
--- a/plugins/gitee/tasks/pr_extractor.go
+++ b/plugins/gitee/tasks/pr_extractor.go
@@ -33,6 +33,7 @@ var ExtractApiPullRequestsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiPullRequests,
 	EnabledByDefault: true,
 	Description:      "Extract raw PullRequests data into tool layer table gitee_pull_requests",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 type GiteeApiPullResponse struct {
diff --git a/plugins/gitee/tasks/pr_issue_convertor.go b/plugins/gitee/tasks/pr_issue_convertor.go
index eab4bae8..a0dced8a 100644
--- a/plugins/gitee/tasks/pr_issue_convertor.go
+++ b/plugins/gitee/tasks/pr_issue_convertor.go
@@ -35,6 +35,7 @@ var ConvertPullRequestIssuesMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertPullRequestIssues,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table gitee_pull_request_issues into  domain layer table pull_request_issues",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ConvertPullRequestIssues(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/pr_issue_enricher.go b/plugins/gitee/tasks/pr_issue_enricher.go
index 9dd4012d..e434e904 100644
--- a/plugins/gitee/tasks/pr_issue_enricher.go
+++ b/plugins/gitee/tasks/pr_issue_enricher.go
@@ -37,6 +37,7 @@ var EnrichPullRequestIssuesMeta = core.SubTaskMeta{
 	EntryPoint:       EnrichPullRequestIssues,
 	EnabledByDefault: true,
 	Description:      "Create tool layer table gitee_pull_request_issues from gitee_pull_reqeusts",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func EnrichPullRequestIssues(taskCtx core.SubTaskContext) (err error) {
diff --git a/plugins/gitee/tasks/pr_label_convertor.go b/plugins/gitee/tasks/pr_label_convertor.go
index c4fbdb39..de351c6d 100644
--- a/plugins/gitee/tasks/pr_label_convertor.go
+++ b/plugins/gitee/tasks/pr_label_convertor.go
@@ -34,6 +34,7 @@ var ConvertPullRequestLabelsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertPullRequestLabels,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table gitee_pull_request_labels into  domain layer table pull_request_labels",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertPullRequestLabels(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/pr_review_collector.go b/plugins/gitee/tasks/pr_review_collector.go
index 88be6d02..6cdba210 100644
--- a/plugins/gitee/tasks/pr_review_collector.go
+++ b/plugins/gitee/tasks/pr_review_collector.go
@@ -40,6 +40,7 @@ var CollectApiPullRequestReviewsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiPullRequestReviews,
 	EnabledByDefault: true,
 	Description:      "Collect PullRequestReviews data from Gitee api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func CollectApiPullRequestReviews(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/pr_review_extractor.go b/plugins/gitee/tasks/pr_review_extractor.go
index 8b863a20..569085c2 100644
--- a/plugins/gitee/tasks/pr_review_extractor.go
+++ b/plugins/gitee/tasks/pr_review_extractor.go
@@ -31,6 +31,7 @@ var ExtractApiPullRequestReviewsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiPullRequestReviews,
 	EnabledByDefault: true,
 	Description:      "Extract raw PullRequestReviews data into tool layer table gitee_reviewers",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 type PullRequestReview struct {
diff --git a/plugins/gitee/tasks/repo_collector.go b/plugins/gitee/tasks/repo_collector.go
index 4fcc4af0..dab28610 100644
--- a/plugins/gitee/tasks/repo_collector.go
+++ b/plugins/gitee/tasks/repo_collector.go
@@ -36,6 +36,7 @@ var CollectApiRepoMeta = core.SubTaskMeta{
 	EntryPoint:  CollectApiRepositories,
 	Required:    true,
 	Description: "Collect repositories data from Gitee api",
+	DomainTypes: []string{core.DOMAIN_TYPE_CODE},
 }
 
 func CollectApiRepositories(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/repo_convertor.go b/plugins/gitee/tasks/repo_convertor.go
index a47ec9fe..029b6542 100644
--- a/plugins/gitee/tasks/repo_convertor.go
+++ b/plugins/gitee/tasks/repo_convertor.go
@@ -37,6 +37,7 @@ var ConvertRepoMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertRepo,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table gitee_repos into  domain layer table repos and boards",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
 
 func ConvertRepo(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitee/tasks/repo_extractor.go b/plugins/gitee/tasks/repo_extractor.go
index 51858352..d465c024 100644
--- a/plugins/gitee/tasks/repo_extractor.go
+++ b/plugins/gitee/tasks/repo_extractor.go
@@ -31,6 +31,7 @@ var ExtractApiRepoMeta = core.SubTaskMeta{
 	EntryPoint:  ExtractApiRepositories,
 	Required:    true,
 	Description: "Extract raw Repositories data into tool layer table gitee_repos",
+	DomainTypes: []string{core.DOMAIN_TYPE_CODE},
 }
 
 type GiteeApiRepoResponse struct {
diff --git a/plugins/gitextractor/tasks/git_repo_collector.go b/plugins/gitextractor/tasks/git_repo_collector.go
index c750de84..3432ed20 100644
--- a/plugins/gitextractor/tasks/git_repo_collector.go
+++ b/plugins/gitextractor/tasks/git_repo_collector.go
@@ -98,6 +98,7 @@ var CollectGitCommitMeta = core.SubTaskMeta{
 	EntryPoint:       CollectGitCommits,
 	EnabledByDefault: true,
 	Description:      "collect git commits into Domain Layer Tables",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE, core.DOMAIN_TYPE_CROSS},
 }
 
 var CollectGitBranchMeta = core.SubTaskMeta{
@@ -105,6 +106,7 @@ var CollectGitBranchMeta = core.SubTaskMeta{
 	EntryPoint:       CollectGitBranches,
 	EnabledByDefault: true,
 	Description:      "collect git branch into Domain Layer Tables",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
 
 var CollectGitTagMeta = core.SubTaskMeta{
@@ -112,4 +114,5 @@ var CollectGitTagMeta = core.SubTaskMeta{
 	EntryPoint:       CollectGitTags,
 	EnabledByDefault: true,
 	Description:      "collect git tag into Domain Layer Tables",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
diff --git a/plugins/github/tasks/account_collector.go b/plugins/github/tasks/account_collector.go
index e46bb6cb..bc39c315 100644
--- a/plugins/github/tasks/account_collector.go
+++ b/plugins/github/tasks/account_collector.go
@@ -94,5 +94,5 @@ var CollectAccountMeta = core.SubTaskMeta{
 	EntryPoint:       CollectAccount,
 	EnabledByDefault: true,
 	Description:      "Collect accounts data from Github api",
-	DomainTypes:      core.DOMAIN_TYPES,
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
diff --git a/plugins/github/tasks/account_convertor.go b/plugins/github/tasks/account_convertor.go
index 70d18c71..54624718 100644
--- a/plugins/github/tasks/account_convertor.go
+++ b/plugins/github/tasks/account_convertor.go
@@ -38,7 +38,7 @@ var ConvertAccountsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertAccounts,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table github_accounts into  domain layer table accounts",
-	DomainTypes:      core.DOMAIN_TYPES,
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 type GithubAccountWithOrg struct {
diff --git a/plugins/github/tasks/account_extractor.go b/plugins/github/tasks/account_extractor.go
index d7daa90d..26fccbb9 100644
--- a/plugins/github/tasks/account_extractor.go
+++ b/plugins/github/tasks/account_extractor.go
@@ -31,7 +31,7 @@ var ExtractAccountMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractAccounts,
 	EnabledByDefault: true,
 	Description:      "Extract raw account data  into tool layer table github_accounts",
-	DomainTypes:      core.DOMAIN_TYPES,
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 type DetailGithubAccountResponse struct {
diff --git a/plugins/github/tasks/comment_collector.go b/plugins/github/tasks/comment_collector.go
index 80da9ca4..d7192260 100644
--- a/plugins/github/tasks/comment_collector.go
+++ b/plugins/github/tasks/comment_collector.go
@@ -130,5 +130,5 @@ var CollectApiCommentsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiComments,
 	EnabledByDefault: true,
 	Description:      "Collect comments data from Github api",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE, core.DOMAIN_TYPE_TICKET},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW, core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/github/tasks/comment_extractor.go b/plugins/github/tasks/comment_extractor.go
index 8e8b6993..d87f4135 100644
--- a/plugins/github/tasks/comment_extractor.go
+++ b/plugins/github/tasks/comment_extractor.go
@@ -35,7 +35,7 @@ var ExtractApiCommentsMeta = core.SubTaskMeta{
 	EnabledByDefault: true,
 	Description: "Extract raw comment data  into tool layer table github_pull_request_comments" +
 		"and github_issue_comments",
-	DomainTypes: []string{core.DOMAIN_TYPE_CODE, core.DOMAIN_TYPE_TICKET},
+	DomainTypes: []string{core.DOMAIN_TYPE_CODE_REVIEW, core.DOMAIN_TYPE_TICKET},
 }
 
 type IssueComment struct {
diff --git a/plugins/github/tasks/milestone_collector.go b/plugins/github/tasks/milestone_collector.go
index ff43bd10..7011bb07 100644
--- a/plugins/github/tasks/milestone_collector.go
+++ b/plugins/github/tasks/milestone_collector.go
@@ -35,6 +35,7 @@ var CollectMilestonesMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiMilestones,
 	EnabledByDefault: true,
 	Description:      "Collect milestone data from Github api",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func CollectApiMilestones(taskCtx core.SubTaskContext) error {
diff --git a/plugins/github/tasks/milestone_converter.go b/plugins/github/tasks/milestone_converter.go
index 069f9623..3af42dc4 100644
--- a/plugins/github/tasks/milestone_converter.go
+++ b/plugins/github/tasks/milestone_converter.go
@@ -34,6 +34,7 @@ var ConvertMilestonesMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertMilestones,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table github_milestones into  domain layer table milestones",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 type MilestoneConverterModel struct {
diff --git a/plugins/github/tasks/milestone_extractor.go b/plugins/github/tasks/milestone_extractor.go
index fc61aa96..c5e70007 100644
--- a/plugins/github/tasks/milestone_extractor.go
+++ b/plugins/github/tasks/milestone_extractor.go
@@ -29,6 +29,7 @@ var ExtractMilestonesMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractMilestones,
 	EnabledByDefault: true,
 	Description:      "Extract raw milestone data into tool layer table github_milestones",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 type MilestonesResponse struct {
diff --git a/plugins/github/tasks/pr_collector.go b/plugins/github/tasks/pr_collector.go
index 9a6905f2..23263209 100644
--- a/plugins/github/tasks/pr_collector.go
+++ b/plugins/github/tasks/pr_collector.go
@@ -40,7 +40,7 @@ var CollectApiPullRequestsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiPullRequests,
 	EnabledByDefault: true,
 	Description:      "Collect PullRequests data from Github api",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func CollectApiPullRequests(taskCtx core.SubTaskContext) error {
diff --git a/plugins/github/tasks/pr_comment_convertor.go b/plugins/github/tasks/pr_comment_convertor.go
index a915721f..71eb586c 100644
--- a/plugins/github/tasks/pr_comment_convertor.go
+++ b/plugins/github/tasks/pr_comment_convertor.go
@@ -34,7 +34,7 @@ var ConvertPullRequestCommentsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertPullRequestComments,
 	EnabledByDefault: true,
 	Description:      "ConvertPullRequestComments data from Github api",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertPullRequestComments(taskCtx core.SubTaskContext) error {
diff --git a/plugins/github/tasks/pr_commit_collector.go b/plugins/github/tasks/pr_commit_collector.go
index c832aa99..dfdcc3b2 100644
--- a/plugins/github/tasks/pr_commit_collector.go
+++ b/plugins/github/tasks/pr_commit_collector.go
@@ -41,7 +41,7 @@ var CollectApiPullRequestCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiPullRequestCommits,
 	EnabledByDefault: true,
 	Description:      "Collect PullRequestCommits data from Github api",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 type SimplePr struct {
diff --git a/plugins/github/tasks/pr_commit_convertor.go b/plugins/github/tasks/pr_commit_convertor.go
index a6aea439..4438db8d 100644
--- a/plugins/github/tasks/pr_commit_convertor.go
+++ b/plugins/github/tasks/pr_commit_convertor.go
@@ -34,7 +34,7 @@ var ConvertPullRequestCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertPullRequestCommits,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table github_pull_request_commits into  domain layer table pull_request_commits",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertPullRequestCommits(taskCtx core.SubTaskContext) (err error) {
diff --git a/plugins/github/tasks/pr_commit_extractor.go b/plugins/github/tasks/pr_commit_extractor.go
index b3e6b4d3..438ace3a 100644
--- a/plugins/github/tasks/pr_commit_extractor.go
+++ b/plugins/github/tasks/pr_commit_extractor.go
@@ -31,7 +31,7 @@ var ExtractApiPullRequestCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiPullRequestCommits,
 	EnabledByDefault: true,
 	Description:      "Extract raw PullRequestCommits data into tool layer table github_commits",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 type PrCommitsResponse struct {
diff --git a/plugins/github/tasks/pr_convertor.go b/plugins/github/tasks/pr_convertor.go
index f0190269..ec4a7b35 100644
--- a/plugins/github/tasks/pr_convertor.go
+++ b/plugins/github/tasks/pr_convertor.go
@@ -35,7 +35,7 @@ var ConvertPullRequestsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertPullRequests,
 	EnabledByDefault: true,
 	Description:      "ConvertPullRequests data from Github api",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertPullRequests(taskCtx core.SubTaskContext) error {
diff --git a/plugins/github/tasks/pr_extractor.go b/plugins/github/tasks/pr_extractor.go
index 3e83ef58..a05289b8 100644
--- a/plugins/github/tasks/pr_extractor.go
+++ b/plugins/github/tasks/pr_extractor.go
@@ -33,7 +33,7 @@ var ExtractApiPullRequestsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiPullRequests,
 	EnabledByDefault: true,
 	Description:      "Extract raw PullRequests data into tool layer table github_pull_requests",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 type GithubApiPullRequest struct {
diff --git a/plugins/github/tasks/pr_issue_convertor.go b/plugins/github/tasks/pr_issue_convertor.go
index 3de1db86..898ad383 100644
--- a/plugins/github/tasks/pr_issue_convertor.go
+++ b/plugins/github/tasks/pr_issue_convertor.go
@@ -34,7 +34,7 @@ var ConvertPullRequestIssuesMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertPullRequestIssues,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table github_pull_request_issues into  domain layer table pull_request_issues",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ConvertPullRequestIssues(taskCtx core.SubTaskContext) error {
diff --git a/plugins/github/tasks/pr_issue_enricher.go b/plugins/github/tasks/pr_issue_enricher.go
index 8c743027..e7c4b37e 100644
--- a/plugins/github/tasks/pr_issue_enricher.go
+++ b/plugins/github/tasks/pr_issue_enricher.go
@@ -36,7 +36,7 @@ var EnrichPullRequestIssuesMeta = core.SubTaskMeta{
 	EntryPoint:       EnrichPullRequestIssues,
 	EnabledByDefault: true,
 	Description:      "Create tool layer table github_pull_request_issues from github_pull_reqeusts",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE, core.DOMAIN_TYPE_TICKET},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func EnrichPullRequestIssues(taskCtx core.SubTaskContext) (err error) {
diff --git a/plugins/github/tasks/pr_label_convertor.go b/plugins/github/tasks/pr_label_convertor.go
index 4a0bf10e..664dbbb2 100644
--- a/plugins/github/tasks/pr_label_convertor.go
+++ b/plugins/github/tasks/pr_label_convertor.go
@@ -34,7 +34,7 @@ var ConvertPullRequestLabelsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertPullRequestLabels,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table github_pull_request_labels into  domain layer table pull_request_labels",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertPullRequestLabels(taskCtx core.SubTaskContext) error {
diff --git a/plugins/github/tasks/pr_review_collector.go b/plugins/github/tasks/pr_review_collector.go
index 38727472..87e2cf31 100644
--- a/plugins/github/tasks/pr_review_collector.go
+++ b/plugins/github/tasks/pr_review_collector.go
@@ -40,7 +40,7 @@ var CollectApiPullRequestReviewsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiPullRequestReviews,
 	EnabledByDefault: true,
 	Description:      "Collect PullRequestReviews data from Github api",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func CollectApiPullRequestReviews(taskCtx core.SubTaskContext) error {
diff --git a/plugins/github/tasks/pr_review_extractor.go b/plugins/github/tasks/pr_review_extractor.go
index c1357c63..7a6971bb 100644
--- a/plugins/github/tasks/pr_review_extractor.go
+++ b/plugins/github/tasks/pr_review_extractor.go
@@ -31,7 +31,7 @@ var ExtractApiPullRequestReviewsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiPullRequestReviews,
 	EnabledByDefault: true,
 	Description:      "Extract raw PullRequestReviewers data into tool layer table github_reviewers",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 type PullRequestReview struct {
diff --git a/plugins/github/tasks/repo_collector.go b/plugins/github/tasks/repo_collector.go
index ae41431a..9f70cff6 100644
--- a/plugins/github/tasks/repo_collector.go
+++ b/plugins/github/tasks/repo_collector.go
@@ -36,7 +36,7 @@ var CollectApiRepoMeta = core.SubTaskMeta{
 	EntryPoint:  CollectApiRepositories,
 	Required:    true,
 	Description: "Collect repositories data from Github api",
-	DomainTypes: core.DOMAIN_TYPES,
+	DomainTypes: []string{core.DOMAIN_TYPE_CODE},
 }
 
 func CollectApiRepositories(taskCtx core.SubTaskContext) error {
diff --git a/plugins/github/tasks/repo_convertor.go b/plugins/github/tasks/repo_convertor.go
index 7809df04..ac3f90bc 100644
--- a/plugins/github/tasks/repo_convertor.go
+++ b/plugins/github/tasks/repo_convertor.go
@@ -37,7 +37,7 @@ var ConvertRepoMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertRepo,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table github_repos into  domain layer table repos and boards",
-	DomainTypes:      core.DOMAIN_TYPES,
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
 
 func ConvertRepo(taskCtx core.SubTaskContext) error {
diff --git a/plugins/github/tasks/repo_extractor.go b/plugins/github/tasks/repo_extractor.go
index e3c8a85f..e5ab717e 100644
--- a/plugins/github/tasks/repo_extractor.go
+++ b/plugins/github/tasks/repo_extractor.go
@@ -31,7 +31,7 @@ var ExtractApiRepoMeta = core.SubTaskMeta{
 	EntryPoint:  ExtractApiRepositories,
 	Required:    true,
 	Description: "Extract raw Repositories data into tool layer table github_repos",
-	DomainTypes: core.DOMAIN_TYPES,
+	DomainTypes: []string{core.DOMAIN_TYPE_CODE},
 }
 
 type ApiRepoResponse GithubApiRepo
diff --git a/plugins/gitlab/tasks/account_collector.go b/plugins/gitlab/tasks/account_collector.go
index 627ca6e5..49824042 100644
--- a/plugins/gitlab/tasks/account_collector.go
+++ b/plugins/gitlab/tasks/account_collector.go
@@ -33,6 +33,7 @@ var CollectAccountMeta = core.SubTaskMeta{
 	EntryPoint:       CollectAccounts,
 	EnabledByDefault: true,
 	Description:      "collect gitlab users",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func CollectAccounts(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/account_extractor.go b/plugins/gitlab/tasks/account_extractor.go
index 31dc0b03..fc46a218 100644
--- a/plugins/gitlab/tasks/account_extractor.go
+++ b/plugins/gitlab/tasks/account_extractor.go
@@ -30,6 +30,7 @@ var ExtractAccountMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractAccounts,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_gitlab_accounts",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ExtractAccounts(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/mr_collector.go b/plugins/gitlab/tasks/mr_collector.go
index 4fec7826..c45b9115 100644
--- a/plugins/gitlab/tasks/mr_collector.go
+++ b/plugins/gitlab/tasks/mr_collector.go
@@ -29,7 +29,7 @@ var CollectApiMergeRequestsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiMergeRequests,
 	EnabledByDefault: true,
 	Description:      "Collect merge requests data from gitlab api",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func CollectApiMergeRequests(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/mr_comment_convertor.go b/plugins/gitlab/tasks/mr_comment_convertor.go
index f7b6208a..f3019827 100644
--- a/plugins/gitlab/tasks/mr_comment_convertor.go
+++ b/plugins/gitlab/tasks/mr_comment_convertor.go
@@ -35,7 +35,7 @@ var ConvertMrCommentMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertMergeRequestComment,
 	EnabledByDefault: true,
 	Description:      "Update domain layer Comment according to GitlabMrComment",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertMergeRequestComment(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/mr_commit_collector.go b/plugins/gitlab/tasks/mr_commit_collector.go
index 6d1aacd0..1374453a 100644
--- a/plugins/gitlab/tasks/mr_commit_collector.go
+++ b/plugins/gitlab/tasks/mr_commit_collector.go
@@ -29,7 +29,7 @@ var CollectApiMrCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiMergeRequestsCommits,
 	EnabledByDefault: true,
 	Description:      "Collect merge requests commits data from gitlab api",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func CollectApiMergeRequestsCommits(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/mr_commit_convertor.go b/plugins/gitlab/tasks/mr_commit_convertor.go
index 76989b8d..68b5eb7a 100644
--- a/plugins/gitlab/tasks/mr_commit_convertor.go
+++ b/plugins/gitlab/tasks/mr_commit_convertor.go
@@ -33,7 +33,7 @@ var ConvertApiMrCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertApiMergeRequestsCommits,
 	EnabledByDefault: true,
 	Description:      "Update domain layer PullRequestCommit according to GitlabMrCommit",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertApiMergeRequestsCommits(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/mr_commit_extractor.go b/plugins/gitlab/tasks/mr_commit_extractor.go
index 4fee993e..f61acf37 100644
--- a/plugins/gitlab/tasks/mr_commit_extractor.go
+++ b/plugins/gitlab/tasks/mr_commit_extractor.go
@@ -29,7 +29,7 @@ var ExtractApiMrCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiMergeRequestsCommits,
 	EnabledByDefault: true,
 	Description:      "Extract raw merge requests commit data into tool layer table GitlabMrCommit and GitlabCommit",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ExtractApiMergeRequestsCommits(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/mr_convertor.go b/plugins/gitlab/tasks/mr_convertor.go
index deba0c77..4d0e7c11 100644
--- a/plugins/gitlab/tasks/mr_convertor.go
+++ b/plugins/gitlab/tasks/mr_convertor.go
@@ -34,7 +34,7 @@ var ConvertApiMergeRequestsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertApiMergeRequests,
 	EnabledByDefault: true,
 	Description:      "Update domain layer PullRequest according to GitlabMergeRequest",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertApiMergeRequests(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/mr_enricher.go b/plugins/gitlab/tasks/mr_enricher.go
index 26376496..405e38ec 100644
--- a/plugins/gitlab/tasks/mr_enricher.go
+++ b/plugins/gitlab/tasks/mr_enricher.go
@@ -32,7 +32,7 @@ var EnrichMergeRequestsMeta = core.SubTaskMeta{
 	EntryPoint:       EnrichMergeRequests,
 	EnabledByDefault: true,
 	Description:      "Enrich merge requests data from GitlabCommit, GitlabMrNote and GitlabMergeRequest",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func EnrichMergeRequests(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/mr_extractor.go b/plugins/gitlab/tasks/mr_extractor.go
index b0bde52e..c165d7bf 100644
--- a/plugins/gitlab/tasks/mr_extractor.go
+++ b/plugins/gitlab/tasks/mr_extractor.go
@@ -73,7 +73,7 @@ var ExtractApiMergeRequestsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiMergeRequests,
 	EnabledByDefault: true,
 	Description:      "Extract raw merge requests data into tool layer table GitlabMergeRequest and GitlabReviewer",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ExtractApiMergeRequests(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/mr_label_convertor.go b/plugins/gitlab/tasks/mr_label_convertor.go
index a9498679..54c4351e 100644
--- a/plugins/gitlab/tasks/mr_label_convertor.go
+++ b/plugins/gitlab/tasks/mr_label_convertor.go
@@ -33,7 +33,7 @@ var ConvertMrLabelsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertMrLabels,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table gitlab_mr_labels into  domain layer table pull_request_labels",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertMrLabels(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/mr_note_collector.go b/plugins/gitlab/tasks/mr_note_collector.go
index 8879742a..44f806e5 100644
--- a/plugins/gitlab/tasks/mr_note_collector.go
+++ b/plugins/gitlab/tasks/mr_note_collector.go
@@ -29,7 +29,7 @@ var CollectApiMrNotesMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiMergeRequestsNotes,
 	EnabledByDefault: true,
 	Description:      "Collect merge requests notes data from gitlab api",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func CollectApiMergeRequestsNotes(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/mr_note_extractor.go b/plugins/gitlab/tasks/mr_note_extractor.go
index a3ae427e..80761168 100644
--- a/plugins/gitlab/tasks/mr_note_extractor.go
+++ b/plugins/gitlab/tasks/mr_note_extractor.go
@@ -46,7 +46,7 @@ var ExtractApiMrNotesMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiMergeRequestsNotes,
 	EnabledByDefault: true,
 	Description:      "Extract raw merge requests notes data into tool layer table GitlabMrNote",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ExtractApiMergeRequestsNotes(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/note_convertor.go b/plugins/gitlab/tasks/note_convertor.go
index 1cb76ba1..7980fefd 100644
--- a/plugins/gitlab/tasks/note_convertor.go
+++ b/plugins/gitlab/tasks/note_convertor.go
@@ -35,7 +35,7 @@ var ConvertApiNotesMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertApiNotes,
 	EnabledByDefault: true,
 	Description:      "Update domain layer Note according to GitlabMrNote",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE_REVIEW},
 }
 
 func ConvertApiNotes(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/pipeline_collector.go b/plugins/gitlab/tasks/pipeline_collector.go
index 63f72f2b..98d16d19 100644
--- a/plugins/gitlab/tasks/pipeline_collector.go
+++ b/plugins/gitlab/tasks/pipeline_collector.go
@@ -29,7 +29,7 @@ var CollectApiPipelinesMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiPipelines,
 	EnabledByDefault: true,
 	Description:      "Collect pipeline data from gitlab api",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
 }
 
 func CollectApiPipelines(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/pipeline_extractor.go b/plugins/gitlab/tasks/pipeline_extractor.go
index 8363bf68..74a57cd0 100644
--- a/plugins/gitlab/tasks/pipeline_extractor.go
+++ b/plugins/gitlab/tasks/pipeline_extractor.go
@@ -55,7 +55,7 @@ var ExtractApiPipelinesMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiPipelines,
 	EnabledByDefault: true,
 	Description:      "Extract raw pipelines data into tool layer table GitlabPipeline",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
 }
 
 func ExtractApiPipelines(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/project_collector.go b/plugins/gitlab/tasks/project_collector.go
index bebc8b63..bd415a14 100644
--- a/plugins/gitlab/tasks/project_collector.go
+++ b/plugins/gitlab/tasks/project_collector.go
@@ -46,7 +46,7 @@ var CollectProjectMeta = core.SubTaskMeta{
 	EntryPoint:       CollectApiProject,
 	EnabledByDefault: true,
 	Description:      "Collect project data from gitlab api",
-	DomainTypes:      core.DOMAIN_TYPES,
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE, core.DOMAIN_TYPE_TICKET},
 }
 
 func CollectApiProject(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/project_convertor.go b/plugins/gitlab/tasks/project_convertor.go
index 18278a00..c1124ec2 100644
--- a/plugins/gitlab/tasks/project_convertor.go
+++ b/plugins/gitlab/tasks/project_convertor.go
@@ -36,7 +36,7 @@ var ConvertProjectMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertApiProjects,
 	EnabledByDefault: true,
 	Description:      "Update domain layer Repo according to GitlabProject",
-	DomainTypes:      core.DOMAIN_TYPES,
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE, core.DOMAIN_TYPE_TICKET},
 }
 
 func ConvertApiProjects(taskCtx core.SubTaskContext) error {
diff --git a/plugins/gitlab/tasks/project_extractor.go b/plugins/gitlab/tasks/project_extractor.go
index 4ef19a17..6f3619c9 100644
--- a/plugins/gitlab/tasks/project_extractor.go
+++ b/plugins/gitlab/tasks/project_extractor.go
@@ -30,7 +30,7 @@ var ExtractProjectMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractApiProject,
 	EnabledByDefault: true,
 	Description:      "Extract raw project data into tool layer table GitlabProject",
-	DomainTypes:      core.DOMAIN_TYPES,
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE, core.DOMAIN_TYPE_TICKET},
 }
 
 // Convert the API response to our DB model instance
diff --git a/plugins/jira/tasks/issue_changelog_collector.go b/plugins/jira/tasks/issue_changelog_collector.go
index fe169d89..03a06c39 100644
--- a/plugins/jira/tasks/issue_changelog_collector.go
+++ b/plugins/jira/tasks/issue_changelog_collector.go
@@ -40,7 +40,7 @@ var CollectIssueChangelogsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectIssueChangelogs,
 	EnabledByDefault: true,
 	Description:      "collect Jira Issue change logs",
-	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET, core.DOMAIN_TYPE_CROSS},
 }
 
 func CollectIssueChangelogs(taskCtx core.SubTaskContext) error {
diff --git a/plugins/jira/tasks/issue_changelog_convertor.go b/plugins/jira/tasks/issue_changelog_convertor.go
index 84a29146..23d27ee6 100644
--- a/plugins/jira/tasks/issue_changelog_convertor.go
+++ b/plugins/jira/tasks/issue_changelog_convertor.go
@@ -38,7 +38,7 @@ var ConvertIssueChangelogsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertIssueChangelogs,
 	EnabledByDefault: true,
 	Description:      "convert Jira Issue change logs",
-	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET, core.DOMAIN_TYPE_CROSS},
 }
 
 type IssueChangelogItemResult struct {
diff --git a/plugins/jira/tasks/issue_changelog_extractor.go b/plugins/jira/tasks/issue_changelog_extractor.go
index 92ce64f9..0499cf63 100644
--- a/plugins/jira/tasks/issue_changelog_extractor.go
+++ b/plugins/jira/tasks/issue_changelog_extractor.go
@@ -33,7 +33,7 @@ var ExtractIssueChangelogsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractIssueChangelogs,
 	EnabledByDefault: true,
 	Description:      "extract Jira Issue change logs",
-	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET, core.DOMAIN_TYPE_CROSS},
 }
 
 func ExtractIssueChangelogs(taskCtx core.SubTaskContext) error {
diff --git a/plugins/jira/tasks/issue_collector.go b/plugins/jira/tasks/issue_collector.go
index f252f940..62e79524 100644
--- a/plugins/jira/tasks/issue_collector.go
+++ b/plugins/jira/tasks/issue_collector.go
@@ -46,7 +46,7 @@ var CollectIssuesMeta = core.SubTaskMeta{
 	EntryPoint:       CollectIssues,
 	EnabledByDefault: true,
 	Description:      "collect Jira issues",
-	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET, core.DOMAIN_TYPE_CROSS},
 }
 
 func CollectIssues(taskCtx core.SubTaskContext) error {
diff --git a/plugins/jira/tasks/issue_commit_convertor.go b/plugins/jira/tasks/issue_commit_convertor.go
index a1174945..2387a83d 100644
--- a/plugins/jira/tasks/issue_commit_convertor.go
+++ b/plugins/jira/tasks/issue_commit_convertor.go
@@ -33,7 +33,7 @@ var ConvertIssueCommitsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertIssueCommits,
 	EnabledByDefault: true,
 	Description:      "convert Jira issue commits",
-	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ConvertIssueCommits(taskCtx core.SubTaskContext) error {
diff --git a/plugins/jira/tasks/issue_extractor.go b/plugins/jira/tasks/issue_extractor.go
index ee50fd13..2a7db48e 100644
--- a/plugins/jira/tasks/issue_extractor.go
+++ b/plugins/jira/tasks/issue_extractor.go
@@ -36,7 +36,7 @@ var ExtractIssuesMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractIssues,
 	EnabledByDefault: true,
 	Description:      "extract Jira issues",
-	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET, core.DOMAIN_TYPE_CROSS},
 }
 
 func ExtractIssues(taskCtx core.SubTaskContext) error {
diff --git a/plugins/refdiff/tasks/ref_commit_diff_calculator.go b/plugins/refdiff/tasks/ref_commit_diff_calculator.go
index a4956604..bfea89a5 100644
--- a/plugins/refdiff/tasks/ref_commit_diff_calculator.go
+++ b/plugins/refdiff/tasks/ref_commit_diff_calculator.go
@@ -148,4 +148,5 @@ var CalculateCommitsDiffMeta = core.SubTaskMeta{
 	EntryPoint:       CalculateCommitsDiff,
 	EnabledByDefault: true,
 	Description:      "Calculate diff commits between refs",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
diff --git a/plugins/refdiff/tasks/ref_issue_diff_calculator.go b/plugins/refdiff/tasks/ref_issue_diff_calculator.go
index 4e938eae..ea2b479a 100644
--- a/plugins/refdiff/tasks/ref_issue_diff_calculator.go
+++ b/plugins/refdiff/tasks/ref_issue_diff_calculator.go
@@ -101,4 +101,5 @@ var CalculateIssuesDiffMeta = core.SubTaskMeta{
 	EntryPoint:       CalculateIssuesDiff,
 	EnabledByDefault: true,
 	Description:      "Calculate diff issues between refs",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
diff --git a/plugins/refdiff/tasks/refs_pr_cherry_pick_calculator.go b/plugins/refdiff/tasks/refs_pr_cherry_pick_calculator.go
index 4659828b..3acbeb8c 100644
--- a/plugins/refdiff/tasks/refs_pr_cherry_pick_calculator.go
+++ b/plugins/refdiff/tasks/refs_pr_cherry_pick_calculator.go
@@ -190,4 +190,5 @@ var CalculatePrCherryPickMeta = core.SubTaskMeta{
 	EntryPoint:       CalculatePrCherryPick,
 	EnabledByDefault: true,
 	Description:      "Calculate pr cherry pick",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CODE},
 }
diff --git a/plugins/tapd/tasks/account_collector.go b/plugins/tapd/tasks/account_collector.go
index a651641d..547d1902 100644
--- a/plugins/tapd/tasks/account_collector.go
+++ b/plugins/tapd/tasks/account_collector.go
@@ -36,6 +36,7 @@ var CollectAccountsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectAccounts,
 	EnabledByDefault: true,
 	Description:      "collect tapd accounts",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func CollectAccounts(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/account_converter.go b/plugins/tapd/tasks/account_converter.go
index dd7c48a7..74a847a3 100644
--- a/plugins/tapd/tasks/account_converter.go
+++ b/plugins/tapd/tasks/account_converter.go
@@ -35,6 +35,7 @@ var ConvertAccountsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertAccounts,
 	EnabledByDefault: true,
 	Description:      "convert tapd account",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ConvertAccounts(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/account_extractor.go b/plugins/tapd/tasks/account_extractor.go
index d0ecb302..05eb4971 100644
--- a/plugins/tapd/tasks/account_extractor.go
+++ b/plugins/tapd/tasks/account_extractor.go
@@ -32,6 +32,7 @@ var ExtractAccountsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractAccounts,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_accounts",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ExtractAccounts(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/bug_changelog_collector.go b/plugins/tapd/tasks/bug_changelog_collector.go
index 948daa2d..ca7fb089 100644
--- a/plugins/tapd/tasks/bug_changelog_collector.go
+++ b/plugins/tapd/tasks/bug_changelog_collector.go
@@ -88,4 +88,5 @@ var CollectBugChangelogMeta = core.SubTaskMeta{
 	EntryPoint:       CollectBugChangelogs,
 	EnabledByDefault: true,
 	Description:      "collect Tapd bugChangelogs",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/bug_changelog_converter.go b/plugins/tapd/tasks/bug_changelog_converter.go
index 2bbaef3d..94851f82 100644
--- a/plugins/tapd/tasks/bug_changelog_converter.go
+++ b/plugins/tapd/tasks/bug_changelog_converter.go
@@ -111,4 +111,5 @@ var ConvertBugChangelogMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertBugChangelog,
 	EnabledByDefault: true,
 	Description:      "convert Tapd bug changelog",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/bug_changelog_extractor.go b/plugins/tapd/tasks/bug_changelog_extractor.go
index 3223be87..0680a7f7 100644
--- a/plugins/tapd/tasks/bug_changelog_extractor.go
+++ b/plugins/tapd/tasks/bug_changelog_extractor.go
@@ -32,6 +32,7 @@ var ExtractBugChangelogMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractBugChangelog,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_bug_changelogs",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractBugChangelog(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/bug_collector.go b/plugins/tapd/tasks/bug_collector.go
index 0b0d7620..3ed97f11 100644
--- a/plugins/tapd/tasks/bug_collector.go
+++ b/plugins/tapd/tasks/bug_collector.go
@@ -90,4 +90,5 @@ var CollectBugMeta = core.SubTaskMeta{
 	EntryPoint:       CollectBugs,
 	EnabledByDefault: true,
 	Description:      "collect Tapd bugs",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/bug_commit_collector.go b/plugins/tapd/tasks/bug_commit_collector.go
index dfeb0015..4cfdb33a 100644
--- a/plugins/tapd/tasks/bug_commit_collector.go
+++ b/plugins/tapd/tasks/bug_commit_collector.go
@@ -122,4 +122,5 @@ var CollectBugCommitMeta = core.SubTaskMeta{
 	EntryPoint:       CollectBugCommits,
 	EnabledByDefault: true,
 	Description:      "collect Tapd issueCommits",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
diff --git a/plugins/tapd/tasks/bug_commit_converter.go b/plugins/tapd/tasks/bug_commit_converter.go
index 0ed30e91..eb20b32b 100644
--- a/plugins/tapd/tasks/bug_commit_converter.go
+++ b/plugins/tapd/tasks/bug_commit_converter.go
@@ -71,4 +71,5 @@ var ConvertBugCommitMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertBugCommit,
 	EnabledByDefault: true,
 	Description:      "convert Tapd BugCommit",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
diff --git a/plugins/tapd/tasks/bug_commit_extractor.go b/plugins/tapd/tasks/bug_commit_extractor.go
index 3cc962b2..c07ce791 100644
--- a/plugins/tapd/tasks/bug_commit_extractor.go
+++ b/plugins/tapd/tasks/bug_commit_extractor.go
@@ -32,6 +32,7 @@ var ExtractBugCommitMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractBugCommits,
 	EnabledByDefault: true,
 	Description:      "Extract raw BugCommits data into tool layer table _tool_tapd_issue_commits",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ExtractBugCommits(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/bug_converter.go b/plugins/tapd/tasks/bug_converter.go
index f20146a1..6a8ab5b7 100644
--- a/plugins/tapd/tasks/bug_converter.go
+++ b/plugins/tapd/tasks/bug_converter.go
@@ -108,4 +108,5 @@ var ConvertBugMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertBug,
 	EnabledByDefault: true,
 	Description:      "convert Tapd Bug",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/bug_custom_fields_collector.go b/plugins/tapd/tasks/bug_custom_fields_collector.go
index c5e2ec97..6cfda606 100644
--- a/plugins/tapd/tasks/bug_custom_fields_collector.go
+++ b/plugins/tapd/tasks/bug_custom_fields_collector.go
@@ -65,4 +65,5 @@ var CollectBugCustomFieldsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectBugCustomFields,
 	EnabledByDefault: true,
 	Description:      "collect Tapd BugCustomFields",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/bug_custom_fields_extractor.go b/plugins/tapd/tasks/bug_custom_fields_extractor.go
index 221748db..26555e38 100644
--- a/plugins/tapd/tasks/bug_custom_fields_extractor.go
+++ b/plugins/tapd/tasks/bug_custom_fields_extractor.go
@@ -32,6 +32,7 @@ var ExtractBugCustomFieldsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractBugCustomFields,
 	EnabledByDefault: true,
 	Description:      "Extract raw company data into tool layer table _tool_tapd_bug_custom_fields",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractBugCustomFields(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/bug_extractor.go b/plugins/tapd/tasks/bug_extractor.go
index 90d12f5b..65344fcd 100644
--- a/plugins/tapd/tasks/bug_extractor.go
+++ b/plugins/tapd/tasks/bug_extractor.go
@@ -36,6 +36,7 @@ var ExtractBugMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractBugs,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_iterations",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractBugs(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/bug_label_convertor.go b/plugins/tapd/tasks/bug_label_convertor.go
index 671cd4d7..353b63ee 100644
--- a/plugins/tapd/tasks/bug_label_convertor.go
+++ b/plugins/tapd/tasks/bug_label_convertor.go
@@ -33,6 +33,7 @@ var ConvertBugLabelsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertBugLabels,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table tapd_issue_labels into  domain layer table issue_labels",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ConvertBugLabels(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/bug_status_collector.go b/plugins/tapd/tasks/bug_status_collector.go
index 4af7b699..745505cb 100644
--- a/plugins/tapd/tasks/bug_status_collector.go
+++ b/plugins/tapd/tasks/bug_status_collector.go
@@ -59,4 +59,5 @@ var CollectBugStatusMeta = core.SubTaskMeta{
 	EntryPoint:       CollectBugStatus,
 	EnabledByDefault: true,
 	Description:      "collect Tapd bugStatus",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/bug_status_extractor.go b/plugins/tapd/tasks/bug_status_extractor.go
index 1e3bc115..8cd538fd 100644
--- a/plugins/tapd/tasks/bug_status_extractor.go
+++ b/plugins/tapd/tasks/bug_status_extractor.go
@@ -32,6 +32,7 @@ var ExtractBugStatusMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractBugStatus,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_bugStatus",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractBugStatus(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/company_collector.go b/plugins/tapd/tasks/company_collector.go
index 445df975..7117f7b5 100644
--- a/plugins/tapd/tasks/company_collector.go
+++ b/plugins/tapd/tasks/company_collector.go
@@ -67,4 +67,5 @@ var CollectCompanyMeta = core.SubTaskMeta{
 	EntryPoint:  CollectCompanies,
 	Required:    false,
 	Description: "collect Tapd companies",
+	DomainTypes: []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/company_extractor.go b/plugins/tapd/tasks/company_extractor.go
index 2c81904d..97bdc670 100644
--- a/plugins/tapd/tasks/company_extractor.go
+++ b/plugins/tapd/tasks/company_extractor.go
@@ -32,6 +32,7 @@ var ExtractCompanyMeta = core.SubTaskMeta{
 	EntryPoint:  ExtractCompanies,
 	Required:    false,
 	Description: "Extract raw company data into tool layer table _tool_tapd_workspaces",
+	DomainTypes: []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractCompanies(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/iteration_collector.go b/plugins/tapd/tasks/iteration_collector.go
index e6598671..8b5416cb 100644
--- a/plugins/tapd/tasks/iteration_collector.go
+++ b/plugins/tapd/tasks/iteration_collector.go
@@ -95,4 +95,5 @@ var CollectIterationMeta = core.SubTaskMeta{
 	EntryPoint:       CollectIterations,
 	EnabledByDefault: true,
 	Description:      "collect Tapd iterations",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/iteration_converter.go b/plugins/tapd/tasks/iteration_converter.go
index 00ced5ff..13108765 100644
--- a/plugins/tapd/tasks/iteration_converter.go
+++ b/plugins/tapd/tasks/iteration_converter.go
@@ -89,4 +89,5 @@ var ConvertIterationMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertIteration,
 	EnabledByDefault: true,
 	Description:      "convert Tapd iteration",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/iteration_extractor.go b/plugins/tapd/tasks/iteration_extractor.go
index afaa009d..cc1d29e9 100644
--- a/plugins/tapd/tasks/iteration_extractor.go
+++ b/plugins/tapd/tasks/iteration_extractor.go
@@ -32,6 +32,7 @@ var ExtractIterationMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractIterations,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_iterations",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractIterations(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/story_bug_collector.go b/plugins/tapd/tasks/story_bug_collector.go
index 3306ee23..8123a940 100644
--- a/plugins/tapd/tasks/story_bug_collector.go
+++ b/plugins/tapd/tasks/story_bug_collector.go
@@ -77,4 +77,5 @@ var CollectStoryBugMeta = core.SubTaskMeta{
 	EntryPoint:       CollectStoryBugs,
 	EnabledByDefault: true,
 	Description:      "collect Tapd storyBugs",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/story_bug_extractor.go b/plugins/tapd/tasks/story_bug_extractor.go
index 559592af..89ac756e 100644
--- a/plugins/tapd/tasks/story_bug_extractor.go
+++ b/plugins/tapd/tasks/story_bug_extractor.go
@@ -32,6 +32,7 @@ var ExtractStoryBugsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractStoryBugs,
 	EnabledByDefault: true,
 	Description:      "Extract raw company data into tool layer table _tool_tapd_story_bugs",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractStoryBugs(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/story_category_collector.go b/plugins/tapd/tasks/story_category_collector.go
index 6260f62e..b4e1193c 100644
--- a/plugins/tapd/tasks/story_category_collector.go
+++ b/plugins/tapd/tasks/story_category_collector.go
@@ -65,4 +65,5 @@ var CollectStoryCategoriesMeta = core.SubTaskMeta{
 	EntryPoint:       CollectStoryCategories,
 	EnabledByDefault: true,
 	Description:      "collect Tapd StoryCategories",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/story_category_extractor.go b/plugins/tapd/tasks/story_category_extractor.go
index 0b641855..72e82558 100644
--- a/plugins/tapd/tasks/story_category_extractor.go
+++ b/plugins/tapd/tasks/story_category_extractor.go
@@ -32,6 +32,7 @@ var ExtractStoryCategoriesMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractStoryCategories,
 	EnabledByDefault: true,
 	Description:      "Extract raw company data into tool layer table _tool_tapd_story_category",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractStoryCategories(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/story_changelog_collector.go b/plugins/tapd/tasks/story_changelog_collector.go
index 5639bb87..c0bfc291 100644
--- a/plugins/tapd/tasks/story_changelog_collector.go
+++ b/plugins/tapd/tasks/story_changelog_collector.go
@@ -87,4 +87,5 @@ var CollectStoryChangelogMeta = core.SubTaskMeta{
 	EntryPoint:       CollectStoryChangelogs,
 	EnabledByDefault: true,
 	Description:      "collect Tapd storyChangelogs",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/story_changelog_converter.go b/plugins/tapd/tasks/story_changelog_converter.go
index bb83573c..95cc9595 100644
--- a/plugins/tapd/tasks/story_changelog_converter.go
+++ b/plugins/tapd/tasks/story_changelog_converter.go
@@ -114,4 +114,5 @@ var ConvertStoryChangelogMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertStoryChangelog,
 	EnabledByDefault: true,
 	Description:      "convert Tapd story changelog",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/story_changelog_extractor.go b/plugins/tapd/tasks/story_changelog_extractor.go
index b8648441..5fd17cd1 100644
--- a/plugins/tapd/tasks/story_changelog_extractor.go
+++ b/plugins/tapd/tasks/story_changelog_extractor.go
@@ -33,6 +33,7 @@ var ExtractStoryChangelogMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractStoryChangelog,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_iterations",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractStoryChangelog(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/story_collector.go b/plugins/tapd/tasks/story_collector.go
index a29975eb..7ae30af1 100644
--- a/plugins/tapd/tasks/story_collector.go
+++ b/plugins/tapd/tasks/story_collector.go
@@ -88,4 +88,5 @@ var CollectStoryMeta = core.SubTaskMeta{
 	EntryPoint:       CollectStorys,
 	EnabledByDefault: true,
 	Description:      "collect Tapd stories",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/story_commit_collector.go b/plugins/tapd/tasks/story_commit_collector.go
index fefa25be..80ba76cd 100644
--- a/plugins/tapd/tasks/story_commit_collector.go
+++ b/plugins/tapd/tasks/story_commit_collector.go
@@ -122,4 +122,5 @@ var CollectStoryCommitMeta = core.SubTaskMeta{
 	EntryPoint:       CollectStoryCommits,
 	EnabledByDefault: true,
 	Description:      "collect Tapd issueCommits",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
diff --git a/plugins/tapd/tasks/story_commit_converter.go b/plugins/tapd/tasks/story_commit_converter.go
index 39139e13..52982884 100644
--- a/plugins/tapd/tasks/story_commit_converter.go
+++ b/plugins/tapd/tasks/story_commit_converter.go
@@ -69,4 +69,5 @@ var ConvertStoryCommitMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertStoryCommit,
 	EnabledByDefault: true,
 	Description:      "convert Tapd StoryCommit",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
diff --git a/plugins/tapd/tasks/story_commit_extractor.go b/plugins/tapd/tasks/story_commit_extractor.go
index 9970a74b..4834ad0f 100644
--- a/plugins/tapd/tasks/story_commit_extractor.go
+++ b/plugins/tapd/tasks/story_commit_extractor.go
@@ -32,6 +32,7 @@ var ExtractStoryCommitMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractStoryCommits,
 	EnabledByDefault: true,
 	Description:      "Extract raw StoryCommits data into tool layer table _tool_tapd_issue_commits",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ExtractStoryCommits(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/story_converter.go b/plugins/tapd/tasks/story_converter.go
index 6304d958..62732e5d 100644
--- a/plugins/tapd/tasks/story_converter.go
+++ b/plugins/tapd/tasks/story_converter.go
@@ -111,4 +111,5 @@ var ConvertStoryMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertStory,
 	EnabledByDefault: true,
 	Description:      "convert Tapd story",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/story_custom_fields_collector.go b/plugins/tapd/tasks/story_custom_fields_collector.go
index 0fd12e9c..1bb8efcd 100644
--- a/plugins/tapd/tasks/story_custom_fields_collector.go
+++ b/plugins/tapd/tasks/story_custom_fields_collector.go
@@ -65,4 +65,5 @@ var CollectStoryCustomFieldsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectStoryCustomFields,
 	EnabledByDefault: true,
 	Description:      "collect Tapd StoryCustomFields",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/story_custom_fields_extractor.go b/plugins/tapd/tasks/story_custom_fields_extractor.go
index 48f70f14..a451c9f3 100644
--- a/plugins/tapd/tasks/story_custom_fields_extractor.go
+++ b/plugins/tapd/tasks/story_custom_fields_extractor.go
@@ -32,6 +32,7 @@ var ExtractStoryCustomFieldsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractStoryCustomFields,
 	EnabledByDefault: true,
 	Description:      "Extract raw company data into tool layer table _tool_tapd_story_custom_fields",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractStoryCustomFields(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/story_extractor.go b/plugins/tapd/tasks/story_extractor.go
index 4cd33e8b..8701f365 100644
--- a/plugins/tapd/tasks/story_extractor.go
+++ b/plugins/tapd/tasks/story_extractor.go
@@ -36,6 +36,7 @@ var ExtractStoryMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractStories,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_iterations",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractStories(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/story_label_convertor.go b/plugins/tapd/tasks/story_label_convertor.go
index 55e382d7..1d7f6033 100644
--- a/plugins/tapd/tasks/story_label_convertor.go
+++ b/plugins/tapd/tasks/story_label_convertor.go
@@ -33,6 +33,7 @@ var ConvertStoryLabelsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertStoryLabels,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table tapd_issue_labels into  domain layer table issue_labels",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ConvertStoryLabels(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/story_status_collector.go b/plugins/tapd/tasks/story_status_collector.go
index 49677d6e..63d1d00d 100644
--- a/plugins/tapd/tasks/story_status_collector.go
+++ b/plugins/tapd/tasks/story_status_collector.go
@@ -59,4 +59,5 @@ var CollectStoryStatusMeta = core.SubTaskMeta{
 	EntryPoint:       CollectStoryStatus,
 	EnabledByDefault: true,
 	Description:      "collect Tapd bugStatus",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/story_status_extractor.go b/plugins/tapd/tasks/story_status_extractor.go
index 026c23b6..0e766154 100644
--- a/plugins/tapd/tasks/story_status_extractor.go
+++ b/plugins/tapd/tasks/story_status_extractor.go
@@ -32,6 +32,7 @@ var ExtractStoryStatusMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractStoryStatus,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_bugStatus",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractStoryStatus(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/sub_workspace_collector.go b/plugins/tapd/tasks/sub_workspace_collector.go
index fe44bb1e..542df6bb 100644
--- a/plugins/tapd/tasks/sub_workspace_collector.go
+++ b/plugins/tapd/tasks/sub_workspace_collector.go
@@ -67,4 +67,5 @@ var CollectSubWorkspaceMeta = core.SubTaskMeta{
 	EntryPoint:       CollectSubWorkspaces,
 	EnabledByDefault: true,
 	Description:      "collect Tapd workspaces",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/sub_workspace_converter.go b/plugins/tapd/tasks/sub_workspace_converter.go
index b8846119..b1f662f7 100644
--- a/plugins/tapd/tasks/sub_workspace_converter.go
+++ b/plugins/tapd/tasks/sub_workspace_converter.go
@@ -73,4 +73,5 @@ var ConvertSubWorkspaceMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertSubWorkspace,
 	EnabledByDefault: true,
 	Description:      "convert Tapd workspace",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/sub_workspace_extractor.go b/plugins/tapd/tasks/sub_workspace_extractor.go
index 036b5d98..86001ef5 100644
--- a/plugins/tapd/tasks/sub_workspace_extractor.go
+++ b/plugins/tapd/tasks/sub_workspace_extractor.go
@@ -32,6 +32,7 @@ var ExtractSubWorkspaceMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractSubWorkspaces,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_workspaces",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractSubWorkspaces(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/task_changelog_collector.go b/plugins/tapd/tasks/task_changelog_collector.go
index 251f31f4..68600ec1 100644
--- a/plugins/tapd/tasks/task_changelog_collector.go
+++ b/plugins/tapd/tasks/task_changelog_collector.go
@@ -88,4 +88,5 @@ var CollectTaskChangelogMeta = core.SubTaskMeta{
 	EntryPoint:       CollectTaskChangelogs,
 	EnabledByDefault: true,
 	Description:      "collect Tapd taskChangelogs",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/task_changelog_converter.go b/plugins/tapd/tasks/task_changelog_converter.go
index 7dd79098..96a924ff 100644
--- a/plugins/tapd/tasks/task_changelog_converter.go
+++ b/plugins/tapd/tasks/task_changelog_converter.go
@@ -114,4 +114,5 @@ var ConvertTaskChangelogMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertTaskChangelog,
 	EnabledByDefault: true,
 	Description:      "convert Tapd task changelog",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/task_changelog_extractor.go b/plugins/tapd/tasks/task_changelog_extractor.go
index 801e33cd..a081d2cb 100644
--- a/plugins/tapd/tasks/task_changelog_extractor.go
+++ b/plugins/tapd/tasks/task_changelog_extractor.go
@@ -33,6 +33,7 @@ var ExtractTaskChangelogMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractTaskChangelog,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_iterations",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractTaskChangelog(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/task_collector.go b/plugins/tapd/tasks/task_collector.go
index b9b272c2..d63e6228 100644
--- a/plugins/tapd/tasks/task_collector.go
+++ b/plugins/tapd/tasks/task_collector.go
@@ -91,4 +91,5 @@ var CollectTaskMeta = core.SubTaskMeta{
 	EntryPoint:       CollectTasks,
 	EnabledByDefault: true,
 	Description:      "collect Tapd tasks",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/task_commit_collector.go b/plugins/tapd/tasks/task_commit_collector.go
index e765f502..a8cfd1bf 100644
--- a/plugins/tapd/tasks/task_commit_collector.go
+++ b/plugins/tapd/tasks/task_commit_collector.go
@@ -122,4 +122,5 @@ var CollectTaskCommitMeta = core.SubTaskMeta{
 	EntryPoint:       CollectTaskCommits,
 	EnabledByDefault: true,
 	Description:      "collect Tapd issueCommits",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
diff --git a/plugins/tapd/tasks/task_commit_converter.go b/plugins/tapd/tasks/task_commit_converter.go
index 26aa1fa9..474a3fde 100644
--- a/plugins/tapd/tasks/task_commit_converter.go
+++ b/plugins/tapd/tasks/task_commit_converter.go
@@ -72,4 +72,5 @@ var ConvertTaskCommitMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertTaskCommit,
 	EnabledByDefault: true,
 	Description:      "convert Tapd TaskCommit",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
diff --git a/plugins/tapd/tasks/task_commit_extractor.go b/plugins/tapd/tasks/task_commit_extractor.go
index 5075d8e6..028afbf0 100644
--- a/plugins/tapd/tasks/task_commit_extractor.go
+++ b/plugins/tapd/tasks/task_commit_extractor.go
@@ -32,6 +32,7 @@ var ExtractTaskCommitMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractTaskCommits,
 	EnabledByDefault: true,
 	Description:      "Extract raw TaskCommits data into tool layer table _tool_tapd_issue_commits",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ExtractTaskCommits(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/task_converter.go b/plugins/tapd/tasks/task_converter.go
index 8b03622b..cba468ba 100644
--- a/plugins/tapd/tasks/task_converter.go
+++ b/plugins/tapd/tasks/task_converter.go
@@ -108,4 +108,5 @@ var ConvertTaskMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertTask,
 	EnabledByDefault: true,
 	Description:      "convert Tapd Task",
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/task_custom_fields_collector.go b/plugins/tapd/tasks/task_custom_fields_collector.go
index e48f8917..b6c5a3fc 100644
--- a/plugins/tapd/tasks/task_custom_fields_collector.go
+++ b/plugins/tapd/tasks/task_custom_fields_collector.go
@@ -65,4 +65,5 @@ var CollectTaskCustomFieldsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectTaskCustomFields,
 	EnabledByDefault: true,
 	Description:      "collect Tapd TaskCustomFields",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
diff --git a/plugins/tapd/tasks/task_custom_fields_extractor.go b/plugins/tapd/tasks/task_custom_fields_extractor.go
index 0be56be7..8db99b6c 100644
--- a/plugins/tapd/tasks/task_custom_fields_extractor.go
+++ b/plugins/tapd/tasks/task_custom_fields_extractor.go
@@ -32,6 +32,7 @@ var ExtractTaskCustomFieldsMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractTaskCustomFields,
 	EnabledByDefault: true,
 	Description:      "Extract raw company data into tool layer table _tool_tapd_task_custom_fields",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ExtractTaskCustomFields(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/task_extractor.go b/plugins/tapd/tasks/task_extractor.go
index ea3b3289..663ed440 100644
--- a/plugins/tapd/tasks/task_extractor.go
+++ b/plugins/tapd/tasks/task_extractor.go
@@ -35,6 +35,7 @@ var ExtractTaskMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractTasks,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_iterations",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ExtractTasks(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/task_label_convertor.go b/plugins/tapd/tasks/task_label_convertor.go
index 56af42c3..a001e23e 100644
--- a/plugins/tapd/tasks/task_label_convertor.go
+++ b/plugins/tapd/tasks/task_label_convertor.go
@@ -33,6 +33,7 @@ var ConvertTaskLabelsMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertTaskLabels,
 	EnabledByDefault: true,
 	Description:      "Convert tool layer table tapd_issue_labels into  domain layer table issue_labels",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ConvertTaskLabels(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/worklog_collector.go b/plugins/tapd/tasks/worklog_collector.go
index 13e3531a..72ea86d0 100644
--- a/plugins/tapd/tasks/worklog_collector.go
+++ b/plugins/tapd/tasks/worklog_collector.go
@@ -87,4 +87,5 @@ var CollectWorklogMeta = core.SubTaskMeta{
 	EntryPoint:       CollectWorklogs,
 	EnabledByDefault: true,
 	Description:      "collect Tapd worklogs",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
diff --git a/plugins/tapd/tasks/worklog_converter.go b/plugins/tapd/tasks/worklog_converter.go
index 17398b91..dd246f11 100644
--- a/plugins/tapd/tasks/worklog_converter.go
+++ b/plugins/tapd/tasks/worklog_converter.go
@@ -91,4 +91,5 @@ var ConvertWorklogMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertWorklog,
 	EnabledByDefault: true,
 	Description:      "convert Tapd Worklog",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
diff --git a/plugins/tapd/tasks/worklog_extractor.go b/plugins/tapd/tasks/worklog_extractor.go
index ea7f1357..9bc92759 100644
--- a/plugins/tapd/tasks/worklog_extractor.go
+++ b/plugins/tapd/tasks/worklog_extractor.go
@@ -32,6 +32,7 @@ var ExtractWorklogMeta = core.SubTaskMeta{
 	EntryPoint:       ExtractWorklogs,
 	EnabledByDefault: true,
 	Description:      "Extract raw workspace data into tool layer table _tool_tapd_iterations",
+	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
 }
 
 func ExtractWorklogs(taskCtx core.SubTaskContext) error {