Schedule in Java SDK

Community Support
1

Hi Temporal team,

Does Temporal Java SDK natively supports schedule? Workflows | Temporal Documentation says we can use the gRPC API and method create Schedule. Can you provide more information/examples for this?

3

@Sowmya

you can use createSchedule method from the WorkflowServiceStubs

E.g.

WorkflowClient client = WorkflowClient.newInstance(service);

    ScheduleSpec.Builder interval =
        ScheduleSpec.newBuilder()
            .addInterval(
                IntervalSpec.newBuilder()
                    .setInterval(com.google.protobuf.Duration.newBuilder().setSeconds(5000).build())
                    .build());
    NewWorkflowExecutionInfo workflowExecutionInfo =
        NewWorkflowExecutionInfo.newBuilder()
            .setWorkflowType(WorkflowType.newBuilder().setName("MyWorkflow").build())
            .setTaskQueue(TaskQueue.newBuilder().setName("taskqueue").build())
            .build();
    client
        .getWorkflowServiceStubs()
        .blockingStub()
        .createSchedule(
            CreateScheduleRequest.newBuilder()
                .setScheduleId("scheduleId")
                .setRequestId("my-request")
                .setNamespace("default")
                .setSchedule(
                    Schedule.newBuilder()
                        .setSpec(interval.build())
                        .setAction(
                            ScheduleAction.newBuilder()
                                .setStartWorkflow(workflowExecutionInfo)
                                .build())
                        .build())
                .build());

I will try to add this to the samples-repo [Feature Request] sample for schedule · Issue #461 · temporalio/samples-java · GitHub

4

This is being actively worked on here and should be done in not too long.

5

Thanks @antonio.perez for the quick reply. @Chad_Retz , Is there any estimate of when this will be available?

6

Not exactly. Hopefully soon (i.e. in master in days or weeks, not months).

7

I just now tried the above example, but facing below error:

io.grpc.StatusRuntimeException: UNIMPLEMENTED: unknown method CreateSchedule for service temporal.api.workflowservice.v1.WorkflowService
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:262)
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:243)
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:156)
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.createSchedule(WorkflowServiceGrpc.java:3643)

Is there something that I’m missing here? Also, where do we specify the workflow that schedule should run? Is it the WorkflowType?

8

Yes, it is the workflow type,

I ran the code above with java-sdk 1.19.1. Which SDK are you using?

9

I had 1.15.1 earlier. Upgraded to 1.19.1 but still facing the same error.

10

that is weird,
can you try cloning the repo and running this example temporal_samples-java/HelloSchedule.java at community_8388 · antmendoza/temporal_samples-java · GitHub ?

Let me know how it goes.

11

Still same error:

Exception in thread "main" io.grpc.StatusRuntimeException: UNIMPLEMENTED: unknown method CreateSchedule for service temporal.api.workflowservice.v1.WorkflowService
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271)
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252)
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165)
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.createSchedule(WorkflowServiceGrpc.java:4164)
	at io.temporal.samples.hello.HelloSchedule.main(HelloSchedule.java:59)

May be this is related to my temporal set up for local. I’m using following docker images:

  1. elasticsearch:7.16.3
  2. postgres:13
  3. temporalio/auto-setup:1.16.2
  4. temporalio/admin-tools:1.16.2
  5. temporalio/ui:0.14.1
  6. temporalio/web:1.15.0
12

I think so @Sowmya

Schedule was added in 1.17 https://github.com/temporalio/temporal/releases/tag/v1.17.0

Can you pull the latest version in your local environment?

13

Worked with latest versions. Thanks

14

Hi @antonio.perez ,

We are good to use schedule feature from the below suggested solution in production, right? Wanted to confirm once.

15

Yes should be ok to use schedules for prod use cases. Would make sure service is on latest version v1.20.3