dapr
/
docs
mirror of https://github.com/dapr/docs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Shortened sample code to show just the necessary pieces 

Signed-off-by: Albert Callarisa <albert@diagrid.io>
This commit is contained in:
Albert Callarisa 2025-09-09 15:16:57 +02:00
parent ce18a7fc0e
commit f5f78a3df7
No known key found for this signature in database
GPG Key ID: 450F38BCAA761685
1 changed files with 14 additions and 121 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

135
daprdocs/content/en/developing-applications/building-blocks/workflow/workflow-multi-app.md
View File

@ -56,60 +56,20 @@ It is paramount that there is co-ordination between the teams owning the differe
<img src="/images/workflow-overview/workflow-multi-app-callactivity.png" width=800 alt="Diagram showing multi-application call activity workflow pattern"> <img src="/images/workflow-overview/workflow-multi-app-callactivity.png" width=800 alt="Diagram showing multi-application call activity workflow pattern">
The following example shows how to execute activities on different target app IDs. The following example shows how to execute the activity `ActivityA` on the target app `App2`.
{{< tabpane text=true >}} {{< tabpane text=true >}}
{{% tab "Go" %}} {{% tab "Go" %}}
```go ```go
package main
import (
"context"
"log"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/client"
"github.com/dapr/durabletask-go/task"
dapr "github.com/dapr/go-sdk/client"
)
func main() {
ctx := context.Background()
registry := task.NewTaskRegistry()
if err := registry.AddOrchestrator(TestWorkflow); err != nil {
log.Fatal(err)
}
daprClient, err := dapr.NewClient()
if err != nil {
log.Fatal(err)
}
client := client.NewTaskHubGrpcClient(daprClient.GrpcClientConn(), backend.DefaultLogger())
if err := client.StartWorkItemListener(ctx, registry); err != nil {
log.Fatal(err)
}
id, err := client.ScheduleNewOrchestration(ctx, "TestWorkflow")
if err != nil {
log.Fatal(err)
}
if _, err = client.WaitForOrchestrationCompletion(ctx, id); err != nil {
log.Fatal(err)
}
}
func TestWorkflow(ctx *task.OrchestrationContext) (any, error) { func TestWorkflow(ctx *task.OrchestrationContext) (any, error) {
var output string var output string
err := ctx.CallActivity("my-other-activity", err := ctx.CallActivity("ActivityA",
task.WithActivityInput("my-input"), task.WithActivityInput("my-input"),
// Here we set custom target app ID which will execute this activity. task.WithActivityAppID("App2"), // Here we set the target app ID which will execute this activity.
task.WithActivityAppID("my-other-app-id"),
).Await(&output) ).Await(&output)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -127,41 +87,14 @@ public class CrossAppWorkflow implements Workflow {
@Override @Override
public WorkflowStub create() { public WorkflowStub create() {
return ctx -> { return ctx -> {
var logger = ctx.getLogger(); String output = ctx.callActivity(
logger.info("=== WORKFLOW STARTING ==="); "ActivityA",
logger.info("Starting CrossAppWorkflow: {}", ctx.getName()); "my-input",
logger.info("Workflow name: {}", ctx.getName()); new WorkflowTaskOptions("App2"), // Here we set the target app ID which will execute this activity.
logger.info("Workflow instance ID: {}", ctx.getInstanceId());
String input = ctx.getInput(String.class);
logger.info("CrossAppWorkflow received input: {}", input);
logger.info("Workflow input: {}", input);
// Call an activity in another app by passing in an active appID to the WorkflowTaskOptions
logger.info("Calling cross-app activity in 'app2'...");
logger.info("About to call cross-app activity in app2...");
String crossAppResult = ctx.callActivity(
App2TransformActivity.class.getName(),
input,
new WorkflowTaskOptions("app2"),
String.class String.class
).await(); ).await();
// Call another activity in a different app ctx.complete(output);
logger.info("Calling cross-app activity in 'app3'...");
logger.info("About to call cross-app activity in app3...");
String finalResult = ctx.callActivity(
App3FinalizeActivity.class.getName(),
crossAppResult,
new WorkflowTaskOptions("app3"),
String.class
).await();
logger.info("Final cross-app activity result: {}", finalResult);
logger.info("Final cross-app activity result: {}", finalResult);
logger.info("CrossAppWorkflow finished with: {}", finalResult);
logger.info("=== WORKFLOW COMPLETING WITH: {} ===" , finalResult);
ctx.complete(finalResult);
}; };
} }
} }
@ -173,62 +106,22 @@ public class CrossAppWorkflow implements Workflow {
## Multi-application child workflow example ## Multi-application child workflow example
The following example shows how to execute child workflows on different target app IDs.
<img src="/images/workflow-overview/workflow-multi-app-child-workflow.png" width=800 alt="Diagram showing multi-application child workflow pattern"> <img src="/images/workflow-overview/workflow-multi-app-child-workflow.png" width=800 alt="Diagram showing multi-application child workflow pattern">
The following example shows how to execute the child workflow `Workflow2` on the target app `App2`.
{{< tabpane text=true >}} {{< tabpane text=true >}}
{{% tab "Go" %}} {{% tab "Go" %}}
```go ```go
package main
import (
"context"
"log"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/client"
"github.com/dapr/durabletask-go/task"
dapr "github.com/dapr/go-sdk/client"
)
func main() {
ctx := context.Background()
registry := task.NewTaskRegistry()
if err := registry.AddOrchestrator(TestWorkflow); err != nil {
log.Fatal(err)
}
daprClient, err := dapr.NewClient()
if err != nil {
log.Fatal(err)
}
client := client.NewTaskHubGrpcClient(daprClient.GrpcClientConn(), backend.DefaultLogger())
if err := client.StartWorkItemListener(ctx, registry); err != nil {
log.Fatal(err)
}
id, err := client.ScheduleNewOrchestration(ctx, "TestWorkflow")
if err != nil {
log.Fatal(err)
}
if _, err = client.WaitForOrchestrationCompletion(ctx, id); err != nil {
log.Fatal(err)
}
}
func TestWorkflow(ctx *task.OrchestrationContext) (any, error) { func TestWorkflow(ctx *task.OrchestrationContext) (any, error) {
var output string var output string
err := ctx.CallSubOrchestrator("my-sub-orchestration", err := ctx.CallSubOrchestrator("Workflow2",
task.WithSubOrchestratorInput("my-input"), task.WithSubOrchestratorInput("my-input"),
// Here we set custom target app ID which will execute this child workflow. task.WithSubOrchestratorAppID("App2"), // Here we set the target app ID which will execute this child workflow.
task.WithSubOrchestratorAppID("my-sub-app-id"),
).Await(&output) ).Await(&output)
if err != nil { if err != nil {
return nil, err return nil, err
} }