[incubator-devlake] branch main updated: fix(jira): add board id filter (#2210)

[kl...@apache.org]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 53f8ef9f fix(jira): add board id filter (#2210)
53f8ef9f is described below

commit 53f8ef9fa8b4520e1ea5ab323da4bc038c2e8b9f
Author: Warren Chen <yi...@merico.dev>
AuthorDate: Wed Jun 15 22:15:36 2022 +0800

    fix(jira): add board id filter (#2210)
    
    closes #2209
---
 plugins/jira/tasks/issue_collector.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/plugins/jira/tasks/issue_collector.go b/plugins/jira/tasks/issue_collector.go
index 40be8c11..49e23f31 100644
--- a/plugins/jira/tasks/issue_collector.go
+++ b/plugins/jira/tasks/issue_collector.go
@@ -48,7 +48,7 @@ func CollectIssues(taskCtx core.SubTaskContext) error {
 	// user didn't specify a time range to sync, try load from database
 	if since == nil {
 		var latestUpdated models.JiraIssue
-		err := db.Where("connection_id = ?", data.Connection.ID).Order("updated DESC").Limit(1).Find(&latestUpdated).Error
+		err := db.Where("connection_id = ? and board_id = ?", data.Connection.ID, data.Options.BoardId).Order("updated DESC").Limit(1).Find(&latestUpdated).Error
 		if err != nil {
 			return fmt.Errorf("failed to get latest jira issue record: %w", err)
 		}