workflows support reuse id policy

Signed-off-by: Fabian Martinez <[email protected]>

Author: famarting

workflow/client.go

@@ -53,6 +53,10 @@ func WithStartTime(time time.Time) api.NewOrchestrationOptions {
 	return api.WithStartTime(time)
 }
 
+func WithReuseIDPolicy(policy *api.OrchestrationIdReusePolicy) api.NewOrchestrationOptions {
+	return api.WithOrchestrationIdReusePolicy(policy)
+}
+
 // WithFetchPayloads is an option to return the payload from a workflow.
 func WithFetchPayloads(fetchPayloads bool) api.FetchOrchestrationMetadataOptions {
 	return api.WithFetchPayloads(fetchPayloads)

workflow/client_test.go

@@ -18,6 +18,7 @@ import (
 	"context"
 	"testing"
 
+	"github.com/microsoft/durabletask-go/api"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
@@ -54,7 +55,10 @@ func TestClientMethods(t *testing.T) {
 	}
 	ctx := context.Background()
 	t.Run("ScheduleNewWorkflow - empty wf name", func(t *testing.T) {
-		id, err := testClient.ScheduleNewWorkflow(ctx, "", nil)
+		id, err := testClient.ScheduleNewWorkflow(ctx, "", WithReuseIDPolicy(&api.OrchestrationIdReusePolicy{
+			OperationStatus: []api.OrchestrationStatus{api.RUNTIME_STATUS_COMPLETED},
+			Action:          api.REUSE_ID_ACTION_IGNORE,
+		}))
 		require.Error(t, err)
 		assert.Empty(t, id)
 	})