NewCreateProcessInstanceCommand with result not works ?

[ArgoTown]

@Zelldon any suggestion how to solve this ?

In docker i pulled latest of zeebe (camunda/zeebe:latest - v8.5.6) image and I used simple code, to start the proccess and get the result of a task

var bpmn = @"<?xml version=""1.0"" encoding=""UTF-8""?>
<bpmn:definitions xmlns:bpmn=""http://www.omg.org/spec/BPMN/20100524/MODEL"" xmlns:bpmndi=""http://www.omg.org/spec/BPMN/20100524/DI"" xmlns:dc=""http://www.omg.org/spec/DD/20100524/DC"" xmlns:zeebe=""http://camunda.org/schema/zeebe/1.0"" xmlns:modeler=""http://camunda.org/schema/modeler/1.0"" xmlns:di=""http://www.omg.org/spec/DD/20100524/DI"" xmlns:camunda=""http://camunda.org/schema/1.0/bpmn"" id=""Definitions_1"" targetNamespace=""http://bpmn.io/schema/bpmn"" exporter=""Camunda Web Modeler"" exporterVersion=""7779555"" modeler:executionPlatform=""Camunda Cloud"" modeler:executionPlatformVersion=""8.5.0"" camunda:diagramRelationId=""e90a0b0b-15e0-48e5-8f5a-5ff7da1762f3"">
  <bpmn:process id=""TestProcess"" name=""Test"" isExecutable=""true"">
    <bpmn:startEvent id=""StartEvent_1"" name=""Start event"">
      <bpmn:outgoing>Flow_1kjn0kj</bpmn:outgoing>
    </bpmn:startEvent>
    <bpmn:sequenceFlow id=""Flow_1kjn0kj"" sourceRef=""StartEvent_1"" targetRef=""TestActivity"" />
    <bpmn:serviceTask id=""TestActivity"" name=""Test"">
      <bpmn:extensionElements>
        <zeebe:taskDefinition type=""test"" />
      </bpmn:extensionElements>
      <bpmn:incoming>Flow_1kjn0kj</bpmn:incoming>
      <bpmn:outgoing>Flow_0mk751m</bpmn:outgoing>
    </bpmn:serviceTask>
    <bpmn:endEvent id=""Event_0msdroy"" name=""End Event"">
      <bpmn:incoming>Flow_0mk751m</bpmn:incoming>
    </bpmn:endEvent>
    <bpmn:sequenceFlow id=""Flow_0mk751m"" sourceRef=""TestActivity"" targetRef=""Event_0msdroy"" />
  </bpmn:process>
  <bpmndi:BPMNDiagram id=""BPMNDiagram_1"">
    <bpmndi:BPMNPlane id=""BPMNPlane_1"" bpmnElement=""TestProcess"">
      <bpmndi:BPMNShape id=""_BPMNShape_StartEvent_2"" bpmnElement=""StartEvent_1"">
        <dc:Bounds x=""150"" y=""100"" width=""36"" height=""36"" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x=""141"" y=""143"" width=""55"" height=""14"" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id=""Activity_06hzxwq_di"" bpmnElement=""TestActivity"">
        <dc:Bounds x=""240"" y=""78"" width=""100"" height=""80"" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id=""Event_0msdroy_di"" bpmnElement=""Event_0msdroy"">
        <dc:Bounds x=""402"" y=""100"" width=""36"" height=""36"" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x=""395"" y=""143"" width=""50"" height=""14"" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge id=""Flow_1kjn0kj_di"" bpmnElement=""Flow_1kjn0kj"">
        <di:waypoint x=""186"" y=""118"" />
        <di:waypoint x=""240"" y=""118"" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id=""Flow_0mk751m_di"" bpmnElement=""Flow_0mk751m"">
        <di:waypoint x=""340"" y=""118"" />
        <di:waypoint x=""402"" y=""118"" />
      </bpmndi:BPMNEdge>
    </bpmndi:BPMNPlane>
  </bpmndi:BPMNDiagram>
</bpmn:definitions>
";

zeebeClient
.NewWorker()
.JobType("test")
.Handler(JobWorker.Test)
.Open();

var resource = await zeebeClient
.NewDeployCommand()
.AddResourceStringUtf8(bpmn, "test.bpmn")
.Send();

var result = await zeebeClient
.NewCreateProcessInstanceCommand()
.BpmnProcessId(resource.Processes.First().BpmnProcessId)
.LatestVersion()
.WithResult()
.SendWithRetry();

Worker

public static class JobWorker
{
    public static async Task Test(IJobClient client, IJob activatedJob)
    {
        await client
            .NewCompleteJobCommand(activatedJob)
            .Variables($"{{ \"Age\": 20}}")
            .Send();
    }
}

But instead i'm getting

Grpc.Core.RpcException: Status(StatusCode="DeadlineExceeded", Detail="Time out between gateway and broker: Request command-api-1 to 172.17.0.2:26501 timed out in PT20S")
   at Zeebe.Client.Impl.Commands.CreateProcessInstanceCommandWithResult.Send(Nullable`1 timeout, CancellationToken token)
   at Zeebe.Client.Impl.Misc.TransientGrpcErrorRetryStrategy.DoWithRetry[TResult](Func`1 action)
   at Zeebe.Client.Impl.Misc.TransientGrpcErrorRetryStrategy.DoWithRetry[TResult](Func`1 action)
   at Zeebe.Client.Impl.Commands.CreateProcessInstanceCommandWithResult.SendWithRetry(Nullable`1 timespan, CancellationToken token)
   at HealthSystem.Api.Controllers.HealthSystemController.GetZeebe()
   at Microsoft.AspNetCore.Mvc.Infrastructure.ActionMethodExecutor.TaskOfIActionResultExecutor.Execute(ActionContext actionContext, IActionResultTypeMapper mapper, ObjectMethodExecutor executor, Object controller, Object[] arguments)
   at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.<InvokeActionMethodAsync>g__Awaited|12_0(ControllerActionInvoker invoker, ValueTask`1 actionResultValueTask)
   at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.<InvokeNextActionFilterAsync>g__Awaited|10_0(ControllerActionInvoker invoker, Task lastTask, State next, Scope scope, Object state, Boolean isCompleted)
   at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.Rethrow(ActionExecutedContextSealed context)
   at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.Next(State& next, Scope& scope, Object& state, Boolean& isCompleted)
   at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.<InvokeInnerFilterAsync>g__Awaited|13_0(ControllerActionInvoker invoker, Task lastTask, State next, Scope scope, Object state, Boolean isCompleted)
   at Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.<InvokeFilterPipelineAsync>g__Awaited|20_0(ResourceInvoker invoker, Task lastTask, State next, Scope scope, Object state, Boolean isCompleted)
   at Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.<InvokeAsync>g__Awaited|17_0(ResourceInvoker invoker, Task task, IDisposable scope)
   at Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.<InvokeAsync>g__Awaited|17_0(ResourceInvoker invoker, Task task, IDisposable scope)
   at Microsoft.AspNetCore.Authorization.AuthorizationMiddleware.Invoke(HttpContext context)
   at Swashbuckle.AspNetCore.SwaggerUI.SwaggerUIMiddleware.Invoke(HttpContext httpContext)
   at Swashbuckle.AspNetCore.Swagger.SwaggerMiddleware.Invoke(HttpContext httpContext, ISwaggerProvider swaggerProvider)
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware.Invoke(HttpContext context)
   at Microsoft.AspNetCore.Diagnostics.DeveloperExceptionPageMiddlewareImpl.Invoke(HttpContext context)

Registered as singleton:

builder.Services.AddSingleton(
ZeebeClient
.Builder()
.UseGatewayAddress("http://localhost:26500")
.UsePlainText()
.UseKeepAlive(TimeSpan.FromSeconds(15))
.Build());

Expected result a success with variables provided in the response, any idea why ?

[ChrisKujawa]

Hey @ArgoTown,

• Was it running before? Did you try it with a earlier version?
• Could you please try without the protocol http://
• Can you try 0.0.0.0

[ArgoTown]

Yes version 8.5.6 and currently tried example, when i put .WithResult() your example ends up to the same error.

[ArgoTown]

Ok weird thing i played around and seems it works if worker defined like in your example and .WithResult() passed.

zeebeClient
.NewWorker()
.JobType("test")
.Handler(JobWorker.Test)
.MaxJobsActive(5)
.Name(nameof(JobWorker))
.AutoCompletion()
.PollInterval(TimeSpan.FromSeconds(1))
.Timeout(TimeSpan.FromSeconds(10))
.Open();

[ChrisKujawa]

Maybe try to remove the lines now one by one to see which was it, maybe we have to open a bug.

But i think it is the max Active

[ArgoTown]

As i mentioned previously MaxJobsActive not a game changer, i tested removing these methods and just .AutoCompletion() have no impact, but if i remove any of these .MaxJobsActive(5), .PollInterval(TimeSpan.FromSeconds(1)), .Timeout(TimeSpan.FromSeconds(10)), then it not works, result the same in error.

[ChrisKujawa]

Thanks 👍 i will take a look