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:28 UTC

[incubator-devlake] branch main updated (3e59c99d -> 88a10296)

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

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


    from 3e59c99d feat(github): collect comments/reviews (#2484)
     new a2e5de37 fix: fill in core.SubTaskMeta.DomainTypes
     new 88a10296 fix: fix DomainTypes for tapd

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 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(-)


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

Posted by wa...@apache.org.
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 {


[incubator-devlake] 02/02: fix: fix DomainTypes for tapd

Posted by wa...@apache.org.
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 88a1029636a40a567500106aab5a5ca0acb4f818
Author: zhangliang <li...@merico.dev>
AuthorDate: Fri Jul 15 23:58:42 2022 +0800

    fix: fix DomainTypes for tapd
---
 plugins/tapd/tasks/task_custom_fields_collector.go | 2 +-
 plugins/tapd/tasks/task_custom_fields_extractor.go | 2 +-
 plugins/tapd/tasks/task_extractor.go               | 2 +-
 plugins/tapd/tasks/task_label_convertor.go         | 2 +-
 plugins/tapd/tasks/worklog_collector.go            | 2 +-
 plugins/tapd/tasks/worklog_converter.go            | 2 +-
 plugins/tapd/tasks/worklog_extractor.go            | 2 +-
 7 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/plugins/tapd/tasks/task_custom_fields_collector.go b/plugins/tapd/tasks/task_custom_fields_collector.go
index b6c5a3fc..4551a763 100644
--- a/plugins/tapd/tasks/task_custom_fields_collector.go
+++ b/plugins/tapd/tasks/task_custom_fields_collector.go
@@ -65,5 +65,5 @@ var CollectTaskCustomFieldsMeta = core.SubTaskMeta{
 	EntryPoint:       CollectTaskCustomFields,
 	EnabledByDefault: true,
 	Description:      "collect Tapd TaskCustomFields",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/task_custom_fields_extractor.go b/plugins/tapd/tasks/task_custom_fields_extractor.go
index 8db99b6c..a601112f 100644
--- a/plugins/tapd/tasks/task_custom_fields_extractor.go
+++ b/plugins/tapd/tasks/task_custom_fields_extractor.go
@@ -32,7 +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},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractTaskCustomFields(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/task_extractor.go b/plugins/tapd/tasks/task_extractor.go
index 663ed440..aae20a05 100644
--- a/plugins/tapd/tasks/task_extractor.go
+++ b/plugins/tapd/tasks/task_extractor.go
@@ -35,7 +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},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 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 a001e23e..6d8f89ad 100644
--- a/plugins/tapd/tasks/task_label_convertor.go
+++ b/plugins/tapd/tasks/task_label_convertor.go
@@ -33,7 +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},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ConvertTaskLabels(taskCtx core.SubTaskContext) error {
diff --git a/plugins/tapd/tasks/worklog_collector.go b/plugins/tapd/tasks/worklog_collector.go
index 72ea86d0..dc93bea9 100644
--- a/plugins/tapd/tasks/worklog_collector.go
+++ b/plugins/tapd/tasks/worklog_collector.go
@@ -87,5 +87,5 @@ var CollectWorklogMeta = core.SubTaskMeta{
 	EntryPoint:       CollectWorklogs,
 	EnabledByDefault: true,
 	Description:      "collect Tapd worklogs",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/worklog_converter.go b/plugins/tapd/tasks/worklog_converter.go
index dd246f11..77390be2 100644
--- a/plugins/tapd/tasks/worklog_converter.go
+++ b/plugins/tapd/tasks/worklog_converter.go
@@ -91,5 +91,5 @@ var ConvertWorklogMeta = core.SubTaskMeta{
 	EntryPoint:       ConvertWorklog,
 	EnabledByDefault: true,
 	Description:      "convert Tapd Worklog",
-	DomainTypes:      []string{core.DOMAIN_TYPE_CROSS},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
diff --git a/plugins/tapd/tasks/worklog_extractor.go b/plugins/tapd/tasks/worklog_extractor.go
index 9bc92759..d021caca 100644
--- a/plugins/tapd/tasks/worklog_extractor.go
+++ b/plugins/tapd/tasks/worklog_extractor.go
@@ -32,7 +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},
+	DomainTypes:      []string{core.DOMAIN_TYPE_TICKET},
 }
 
 func ExtractWorklogs(taskCtx core.SubTaskContext) error {