ovh
diff --git a/‎cli/cdsctl/workflow_run.go
Lines changed: 16 additions & 0 deletions b/‎cli/cdsctl/workflow_run.go
Lines changed: 16 additions & 0 deletions
diff --git a/‎sdk/cdsclient/client_workflow.go
Lines changed: 9 additions & 0 deletions b/‎sdk/cdsclient/client_workflow.go
Lines changed: 9 additions & 0 deletions
diff --git a/‎sdk/cdsclient/interface.go
Lines changed: 1 addition & 0 deletions b/‎sdk/cdsclient/interface.go
Lines changed: 1 addition & 0 deletions
@@ -83,10 +83,20 @@ var workflowRunManualCmd = cli.Command{
 			Usage:     "Open web browser on the workflow run",
 			Kind:      reflect.Bool,
 		},
+		{
+			Name:      "sync",
+			ShortHand: "s",
+			Usage:     "Synchronise your pipelines with your last editions. Must be used with flag run-number",
+			Kind:      reflect.Bool,
+		},
 	},
 }
 
 func workflowRunManualRun(v cli.Values) error {
+	if v.GetBool("sync") && v.GetString("run-number") == "" {
+		return fmt.Errorf("Could not use flag --sync without flag --run-number")
+	}
+
 	manual := sdk.WorkflowNodeRunManual{}
 	if strings.TrimSpace(v.GetString("data")) != "" {
 		data := map[string]interface{}{}
@@ -133,6 +143,12 @@ func workflowRunManualRun(v cli.Values) error {
 		}
 	}
 
+	if v.GetBool("sync") {
+		if _, err := client.WorkflowRunResync(v[_ProjectKey], v[_WorkflowName], runNumber); err != nil {
+			return fmt.Errorf("Cannot resync your workflow run %d : %v", runNumber, err)
+		}
+	}
+
 	if v.GetString("node-name") != "" {
 		if runNumber <= 0 {
 			return fmt.Errorf("You can use flag node-name without flag run-number")
 
@@ -41,6 +41,15 @@ func (c *client) WorkflowRunGet(projectKey string, workflowName string, number i
 	return &run, nil
 }
 
+func (c *client) WorkflowRunResync(projectKey string, workflowName string, number int64) (*sdk.WorkflowRun, error) {
+	url := fmt.Sprintf("/project/%s/workflows/%s/runs/%d/resync", projectKey, workflowName, number)
+	var run sdk.WorkflowRun
+	if _, err := c.PostJSON(context.Background(), url, nil, &run); err != nil {
+		return nil, err
+	}
+	return &run, nil
+}
+
 func (c *client) WorkflowRunSearch(projectKey string, offset, limit int64, filters ...Filter) ([]sdk.WorkflowRun, error) {
 	if offset < 0 {
 		offset = 0
 
@@ -273,6 +273,7 @@ type WorkflowClient interface {
 	WorkflowGet(projectKey, name string) (*sdk.Workflow, error)
 	WorkflowDelete(projectKey string, workflowName string) error
 	WorkflowRunGet(projectKey string, workflowName string, number int64) (*sdk.WorkflowRun, error)
+	WorkflowRunResync(projectKey string, workflowName string, number int64) (*sdk.WorkflowRun, error)
 	WorkflowRunSearch(projectKey string, offset, limit int64, filter ...Filter) ([]sdk.WorkflowRun, error)
 	WorkflowRunList(projectKey string, workflowName string, offset, limit int64) ([]sdk.WorkflowRun, error)
 	WorkflowRunArtifacts(projectKey string, name string, number int64) ([]sdk.WorkflowNodeRunArtifact, error)