[incubator-devlake] branch fix#6075 updated: fix: jira incremental collectors

[abeizn]

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

abeizn pushed a commit to branch fix#6075
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git


The following commit(s) were added to refs/heads/fix#6075 by this push:
     new 87bef4060 fix: jira incremental collectors
87bef4060 is described below

commit 87bef4060b4b48f691e044d1ef9cb3623c9897a3
Author: abeizn <zikuan...@merico.dev>
AuthorDate: Wed Sep 13 18:11:49 2023 +0800

    fix: jira incremental collectors
---
 backend/plugins/jira/tasks/issue_collector.go | 9 +--------
 1 file changed, 1 insertion(+), 8 deletions(-)

diff --git a/backend/plugins/jira/tasks/issue_collector.go 
b/backend/plugins/jira/tasks/issue_collector.go
index a6cf3b8ea..b00cd4ff3 100644
--- a/backend/plugins/jira/tasks/issue_collector.go
+++ b/backend/plugins/jira/tasks/issue_collector.go
@@ -77,14 +77,7 @@ func CollectIssues(taskCtx plugin.SubTaskContext) 
errors.Error {
        } else {
                logger.Info("got user's timezone: %v", loc.String())
        }
-
-       jql := ""
-       syncPolicy := taskCtx.TaskContext().SyncPolicy()
-       if syncPolicy != nil && syncPolicy.TimeAfter != nil {
-               jql = buildJQL(syncPolicy.TimeAfter, 
collectorWithState.LatestState.LatestSuccessStart, incremental, loc)
-       } else {
-               jql = buildJQL(nil, 
collectorWithState.LatestState.LatestSuccessStart, incremental, loc)
-       }
+       jql := buildJQL(collectorWithState.TimeAfter, 
collectorWithState.LatestState.LatestSuccessStart, incremental, loc)
 
        err = collectorWithState.InitCollector(api.ApiCollectorArgs{
                ApiClient:   data.ApiClient,