Skip to content

Commit

Permalink
clean up
Browse files Browse the repository at this point in the history
Signed-off-by: kaibocai <kaibocai@microsoft.com>
  • Loading branch information
kaibocai committed Dec 15, 2023
1 parent 6417134 commit e927c1b
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions pkg/runtime/wfengine/backend.go
Original file line number Diff line number Diff line change
Expand Up @@ -156,14 +156,14 @@ func (be *actorBackend) CreateOrchestrationInstance(ctx context.Context, e *back
EventData: eventData,
}

rawDataBytes, _ := json.Marshal(policyAndEventData)
policyAndEventDataBytes, _ := json.Marshal(policyAndEventData)

// Invoke the well-known workflow actor directly, which will be created by this invocation
// request. Note that this request goes directly to the actor runtime, bypassing the API layer.
req := invokev1.
NewInvokeMethodRequest(CreateWorkflowInstanceMethod).
WithActor(be.config.workflowActorType, workflowInstanceID).
WithRawDataBytes(rawDataBytes).
WithRawDataBytes(policyAndEventDataBytes).
WithContentType(invokev1.OctetStreamContentType)
defer req.Close()

Expand Down
2 changes: 1 addition & 1 deletion pkg/runtime/wfengine/workflow.go
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ func (err recoverableError) Error() string {
func NewWorkflowActor(scheduler workflowScheduler, config actorsBackendConfig) *workflowActor {
return &workflowActor{
scheduler: scheduler,
defaultTimeout: 300 * time.Minute,
defaultTimeout: 30 * time.Second,
reminderInterval: 1 * time.Minute,
config: config,
}
Expand Down

0 comments on commit e927c1b

Please sign in to comment.