You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@devlake.apache.org by kl...@apache.org on 2024/01/16 05:56:20 UTC
(incubator-devlake) branch kw-feat-directrun-supports-fullsync created (now d82efeb34)
This is an automated email from the ASF dual-hosted git repository.
klesh pushed a change to branch kw-feat-directrun-supports-fullsync
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git
at d82efeb34 feat: add fullsync flag to DirectRun
This branch includes the following new commits:
new d82efeb34 feat: add fullsync flag to DirectRun
The 1 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.
(incubator-devlake) 01/01: feat: add fullsync flag to DirectRun
Posted by kl...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
klesh pushed a commit to branch kw-feat-directrun-supports-fullsync
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git
commit d82efeb341715a96f08de5cbb7c94d7d26250643
Author: Klesh Wong <zh...@merico.dev>
AuthorDate: Tue Jan 16 13:55:32 2024 +0800
feat: add fullsync flag to DirectRun
---
backend/core/runner/directrun.go | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/backend/core/runner/directrun.go b/backend/core/runner/directrun.go
index 8d596651d..47c440706 100644
--- a/backend/core/runner/directrun.go
+++ b/backend/core/runner/directrun.go
@@ -37,6 +37,7 @@ import (
// RunCmd FIXME ...
func RunCmd(cmd *cobra.Command) {
cmd.Flags().StringSliceP("subtasks", "t", nil, "specify what tasks to run, --subtasks=collectIssues,extractIssues")
+ cmd.Flags().BoolP("fullsync", "f", false, "run fullsync")
err := cmd.Execute()
if err != nil {
panic(err)
@@ -54,6 +55,10 @@ func DirectRun(cmd *cobra.Command, args []string, pluginTask plugin.PluginTask,
if err != nil {
panic(err)
}
+ fullSync, err := cmd.Flags().GetBool("fullsync")
+ if err != nil {
+ panic(err)
+ }
if pluginInit, ok := pluginTask.(plugin.PluginInit); ok {
err = pluginInit.Init(basicRes)
if err != nil {
@@ -94,6 +99,7 @@ func DirectRun(cmd *cobra.Command, args []string, pluginTask plugin.PluginTask,
}
syncPolicy.TimeAfter = &parsedTimeAfter
}
+ syncPolicy.FullSync = fullSync
err = RunPluginSubTasks(
ctx,