diff --git a/.github/workflows/certification.yml b/.github/workflows/certification.yml.disabled similarity index 100% rename from .github/workflows/certification.yml rename to .github/workflows/certification.yml.disabled diff --git a/tests/conformance/workflows/workflows.go b/tests/conformance/workflows/workflows.go index 7e8e3310af..180ef1cf77 100644 --- a/tests/conformance/workflows/workflows.go +++ b/tests/conformance/workflows/workflows.go @@ -15,12 +15,12 @@ package workflows import ( "context" - "encoding/json" "testing" "time" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" + "google.golang.org/protobuf/types/known/wrapperspb" "github.com/dapr/kit/logger" @@ -61,14 +61,12 @@ func ConformanceTests(t *testing.T, props map[string]string, workflowItem workfl t.Run("start", func(t *testing.T) { testLogger.Info("Start test running...") - inputBytes, _ := json.Marshal(10) // Time that the activity within the workflow runs for - testInstanceID := "TestID" t.Run("start", func(t *testing.T) { req := &workflows.StartRequest{ - InstanceID: testInstanceID, + InstanceID: &testInstanceID, WorkflowName: "TestWorkflow", - WorkflowInput: inputBytes, + WorkflowInput: wrapperspb.String("10"), Options: map[string]string{ "task_queue": "TestTaskQueue", }, diff --git a/workflows/requests.go b/workflows/requests.go index 7f4019c729..fcc7a9e6c1 100644 --- a/workflows/requests.go +++ b/workflows/requests.go @@ -1,11 +1,13 @@ package workflows +import "google.golang.org/protobuf/types/known/wrapperspb" + // StartRequest is the struct describing a start workflow request. type StartRequest struct { - InstanceID string `json:"instanceID"` - Options map[string]string `json:"options"` - WorkflowName string `json:"workflowName"` - WorkflowInput []byte `json:"workflowInput"` + InstanceID *string `json:"instanceID"` + Options map[string]string `json:"options"` + WorkflowName string `json:"workflowName"` + WorkflowInput *wrapperspb.StringValue `json:"workflowInput"` } // GetRequest is the struct describing a get workflow state request. @@ -16,14 +18,14 @@ type GetRequest struct { // TerminateRequest is the struct describing a terminate workflow request. type TerminateRequest struct { InstanceID string `json:"instanceID"` - Recursive bool `json:"recursive"` + Recursive *bool `json:"recursive"` } // RaiseEventRequest is the struct describing a raise workflow event request. type RaiseEventRequest struct { - InstanceID string `json:"instanceID"` - EventName string `json:"name"` - EventData []byte `json:"data"` + InstanceID string `json:"instanceID"` + EventName string `json:"name"` + EventData *wrapperspb.StringValue `json:"data"` } // PauseRequest is the struct describing a pause workflow request. @@ -39,5 +41,5 @@ type ResumeRequest struct { // PurgeRequest is the object describing a Purge request. type PurgeRequest struct { InstanceID string `json:"instanceID"` - Recursive bool `json:"recursive"` + Recursive *bool `json:"recursive"` }