Skip to content

Commit 1b2a2ce

Browse files
vancexuvancexu
authored
Sync IDLs and add new APIs
2 parents b8e4db5 + 4e89ea8 commit 1b2a2ce

File tree

12 files changed

+689
-5
lines changed

12 files changed

+689
-5
lines changed

‎docker/buildkite/docker-compose-local.yaml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ services:
2323
- statsd
2424

2525
cadence:
26-
image: ubercadence/server:0.5.6
26+
image: ubercadence/server:master-auto-setup
2727
ports:
2828
- "7933:7933"
2929
- "7934:7934"

‎docker/buildkite/docker-compose.yaml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ services:
2323
- statsd
2424

2525
cadence:
26-
image: ubercadence/server:0.5.9
26+
image: ubercadence/server:master-auto-setup
2727
ports:
2828
- "7933:7933"
2929
- "7934:7934"

‎src/main/java/com/uber/cadence/internal/common/WorkflowExecutionUtils.java‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1002,6 +1002,8 @@ public static EventType getEventTypeForDecision(DecisionType decisionType) {
10021002
return EventType.StartChildWorkflowExecutionInitiated;
10031003
case SignalExternalWorkflowExecution:
10041004
return EventType.SignalExternalWorkflowExecutionInitiated;
1005+
case UpsertWorkflowSearchAttributes:
1006+
return EventType.UpsertWorkflowSearchAttributes;
10051007
}
10061008
throw new IllegalArgumentException("Unknown decisionType");
10071009
}

‎src/main/java/com/uber/cadence/internal/metrics/ServiceMethod.java‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,14 @@ public class ServiceMethod {
2929
MetricsType.CADENCE_METRICS_PREFIX + "ListClosedWorkflowExecutions";
3030
public static final String LIST_OPEN_WORKFLOW_EXECUTIONS =
3131
MetricsType.CADENCE_METRICS_PREFIX + "ListOpenWorkflowExecutions";
32+
public static final String LIST_WORKFLOW_EXECUTIONS =
33+
MetricsType.CADENCE_METRICS_PREFIX + "ListWorkflowExecutions";
34+
public static final String SCAN_WORKFLOW_EXECUTIONS =
35+
MetricsType.CADENCE_METRICS_PREFIX + "ScanWorkflowExecutions";
36+
public static final String COUNT_WORKFLOW_EXECUTIONS =
37+
MetricsType.CADENCE_METRICS_PREFIX + "CountWorkflowExecutions";
38+
public static final String GET_SEARCH_ATTRIBUTES =
39+
MetricsType.CADENCE_METRICS_PREFIX + "GetSearchAttributes";
3240
public static final String POLL_FOR_ACTIVITY_TASK =
3341
MetricsType.CADENCE_METRICS_PREFIX + "PollForActivityTask";
3442
public static final String POLL_FOR_DECISION_TASK =

‎src/main/java/com/uber/cadence/internal/replay/ReplayDecider.java‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -228,6 +228,9 @@ private void processEvent(HistoryEvent event) {
228228
case DecisionTaskFailed:
229229
context.handleDecisionTaskFailed(event);
230230
break;
231+
case UpsertWorkflowSearchAttributes:
232+
// TODO: https://github.com/uber/cadence-java-client/issues/360
233+
break;
231234
}
232235
}
233236

‎src/main/java/com/uber/cadence/internal/sync/TestActivityEnvironmentInternal.java‎

Lines changed: 79 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,9 @@
2121
import com.uber.cadence.ActivityType;
2222
import com.uber.cadence.BadRequestError;
2323
import com.uber.cadence.CancellationAlreadyRequestedError;
24+
import com.uber.cadence.ClientVersionNotSupportedError;
25+
import com.uber.cadence.CountWorkflowExecutionsRequest;
26+
import com.uber.cadence.CountWorkflowExecutionsResponse;
2427
import com.uber.cadence.DeprecateDomainRequest;
2528
import com.uber.cadence.DescribeDomainRequest;
2629
import com.uber.cadence.DescribeDomainResponse;
@@ -31,6 +34,7 @@
3134
import com.uber.cadence.DomainAlreadyExistsError;
3235
import com.uber.cadence.DomainNotActiveError;
3336
import com.uber.cadence.EntityNotExistsError;
37+
import com.uber.cadence.GetSearchAttributesResponse;
3438
import com.uber.cadence.GetWorkflowExecutionHistoryRequest;
3539
import com.uber.cadence.GetWorkflowExecutionHistoryResponse;
3640
import com.uber.cadence.InternalServiceError;
@@ -41,6 +45,8 @@
4145
import com.uber.cadence.ListDomainsResponse;
4246
import com.uber.cadence.ListOpenWorkflowExecutionsRequest;
4347
import com.uber.cadence.ListOpenWorkflowExecutionsResponse;
48+
import com.uber.cadence.ListWorkflowExecutionsRequest;
49+
import com.uber.cadence.ListWorkflowExecutionsResponse;
4450
import com.uber.cadence.PollForActivityTaskRequest;
4551
import com.uber.cadence.PollForActivityTaskResponse;
4652
import com.uber.cadence.PollForDecisionTaskRequest;
@@ -55,6 +61,8 @@
5561
import com.uber.cadence.RequestCancelWorkflowExecutionRequest;
5662
import com.uber.cadence.ResetStickyTaskListRequest;
5763
import com.uber.cadence.ResetStickyTaskListResponse;
64+
import com.uber.cadence.ResetWorkflowExecutionRequest;
65+
import com.uber.cadence.ResetWorkflowExecutionResponse;
5866
import com.uber.cadence.RespondActivityTaskCanceledByIDRequest;
5967
import com.uber.cadence.RespondActivityTaskCanceledRequest;
6068
import com.uber.cadence.RespondActivityTaskCompletedByIDRequest;
@@ -471,6 +479,14 @@ public StartWorkflowExecutionResponse SignalWithStartWorkflowExecution(
471479
return impl.SignalWithStartWorkflowExecution(signalWithStartRequest);
472480
}
473481

482+
@Override
483+
public ResetWorkflowExecutionResponse ResetWorkflowExecution(
484+
ResetWorkflowExecutionRequest resetRequest)
485+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
486+
DomainNotActiveError, LimitExceededError, ClientVersionNotSupportedError, TException {
487+
return impl.ResetWorkflowExecution(resetRequest);
488+
}
489+
474490
@Override
475491
public void TerminateWorkflowExecution(TerminateWorkflowExecutionRequest terminateRequest)
476492
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
@@ -494,6 +510,36 @@ public ListClosedWorkflowExecutionsResponse ListClosedWorkflowExecutions(
494510
return impl.ListClosedWorkflowExecutions(listRequest);
495511
}
496512

513+
@Override
514+
public ListWorkflowExecutionsResponse ListWorkflowExecutions(
515+
ListWorkflowExecutionsRequest listRequest)
516+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
517+
ClientVersionNotSupportedError, TException {
518+
return impl.ListWorkflowExecutions(listRequest);
519+
}
520+
521+
@Override
522+
public ListWorkflowExecutionsResponse ScanWorkflowExecutions(
523+
ListWorkflowExecutionsRequest listRequest)
524+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
525+
ClientVersionNotSupportedError, TException {
526+
return impl.ScanWorkflowExecutions(listRequest);
527+
}
528+
529+
@Override
530+
public CountWorkflowExecutionsResponse CountWorkflowExecutions(
531+
CountWorkflowExecutionsRequest countRequest)
532+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
533+
ClientVersionNotSupportedError, TException {
534+
return impl.CountWorkflowExecutions(countRequest);
535+
}
536+
537+
@Override
538+
public GetSearchAttributesResponse GetSearchAttributes()
539+
throws InternalServiceError, ServiceBusyError, ClientVersionNotSupportedError, TException {
540+
return impl.GetSearchAttributes();
541+
}
542+
497543
@Override
498544
public void RespondQueryTaskCompleted(RespondQueryTaskCompletedRequest completeRequest)
499545
throws BadRequestError, InternalServiceError, EntityNotExistsError, TException {
@@ -680,6 +726,13 @@ public void SignalWithStartWorkflowExecution(
680726
impl.SignalWithStartWorkflowExecution(signalWithStartRequest, resultHandler);
681727
}
682728

729+
@Override
730+
public void ResetWorkflowExecution(
731+
ResetWorkflowExecutionRequest resetRequest, AsyncMethodCallback resultHandler)
732+
throws TException {
733+
impl.ResetWorkflowExecution(resetRequest, resultHandler);
734+
}
735+
683736
@Override
684737
public void TerminateWorkflowExecution(
685738
TerminateWorkflowExecutionRequest terminateRequest, AsyncMethodCallback resultHandler)
@@ -701,6 +754,32 @@ public void ListClosedWorkflowExecutions(
701754
impl.ListClosedWorkflowExecutions(listRequest, resultHandler);
702755
}
703756

757+
@Override
758+
public void ListWorkflowExecutions(
759+
ListWorkflowExecutionsRequest listRequest, AsyncMethodCallback resultHandler)
760+
throws TException {
761+
impl.ListWorkflowExecutions(listRequest, resultHandler);
762+
}
763+
764+
@Override
765+
public void ScanWorkflowExecutions(
766+
ListWorkflowExecutionsRequest listRequest, AsyncMethodCallback resultHandler)
767+
throws TException {
768+
impl.ScanWorkflowExecutions(listRequest, resultHandler);
769+
}
770+
771+
@Override
772+
public void CountWorkflowExecutions(
773+
CountWorkflowExecutionsRequest countRequest, AsyncMethodCallback resultHandler)
774+
throws TException {
775+
impl.CountWorkflowExecutions(countRequest, resultHandler);
776+
}
777+
778+
@Override
779+
public void GetSearchAttributes(AsyncMethodCallback resultHandler) throws TException {
780+
impl.GetSearchAttributes(resultHandler);
781+
}
782+
704783
@Override
705784
public void RespondQueryTaskCompleted(
706785
RespondQueryTaskCompletedRequest completeRequest, AsyncMethodCallback resultHandler)

‎src/main/java/com/uber/cadence/internal/sync/TestWorkflowEnvironmentInternal.java‎

Lines changed: 79 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,9 @@
1919

2020
import com.uber.cadence.BadRequestError;
2121
import com.uber.cadence.CancellationAlreadyRequestedError;
22+
import com.uber.cadence.ClientVersionNotSupportedError;
23+
import com.uber.cadence.CountWorkflowExecutionsRequest;
24+
import com.uber.cadence.CountWorkflowExecutionsResponse;
2225
import com.uber.cadence.DeprecateDomainRequest;
2326
import com.uber.cadence.DescribeDomainRequest;
2427
import com.uber.cadence.DescribeDomainResponse;
@@ -29,6 +32,7 @@
2932
import com.uber.cadence.DomainAlreadyExistsError;
3033
import com.uber.cadence.DomainNotActiveError;
3134
import com.uber.cadence.EntityNotExistsError;
35+
import com.uber.cadence.GetSearchAttributesResponse;
3236
import com.uber.cadence.GetWorkflowExecutionHistoryRequest;
3337
import com.uber.cadence.GetWorkflowExecutionHistoryResponse;
3438
import com.uber.cadence.InternalServiceError;
@@ -39,6 +43,8 @@
3943
import com.uber.cadence.ListDomainsResponse;
4044
import com.uber.cadence.ListOpenWorkflowExecutionsRequest;
4145
import com.uber.cadence.ListOpenWorkflowExecutionsResponse;
46+
import com.uber.cadence.ListWorkflowExecutionsRequest;
47+
import com.uber.cadence.ListWorkflowExecutionsResponse;
4248
import com.uber.cadence.PollForActivityTaskRequest;
4349
import com.uber.cadence.PollForActivityTaskResponse;
4450
import com.uber.cadence.PollForDecisionTaskRequest;
@@ -53,6 +59,8 @@
5359
import com.uber.cadence.RequestCancelWorkflowExecutionRequest;
5460
import com.uber.cadence.ResetStickyTaskListRequest;
5561
import com.uber.cadence.ResetStickyTaskListResponse;
62+
import com.uber.cadence.ResetWorkflowExecutionRequest;
63+
import com.uber.cadence.ResetWorkflowExecutionResponse;
5664
import com.uber.cadence.RespondActivityTaskCanceledByIDRequest;
5765
import com.uber.cadence.RespondActivityTaskCanceledRequest;
5866
import com.uber.cadence.RespondActivityTaskCompletedByIDRequest;
@@ -326,6 +334,14 @@ public StartWorkflowExecutionResponse SignalWithStartWorkflowExecution(
326334
return impl.SignalWithStartWorkflowExecution(signalWithStartRequest);
327335
}
328336

337+
@Override
338+
public ResetWorkflowExecutionResponse ResetWorkflowExecution(
339+
ResetWorkflowExecutionRequest resetRequest)
340+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
341+
DomainNotActiveError, LimitExceededError, ClientVersionNotSupportedError, TException {
342+
return impl.ResetWorkflowExecution(resetRequest);
343+
}
344+
329345
@Override
330346
public void TerminateWorkflowExecution(TerminateWorkflowExecutionRequest terminateRequest)
331347
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
@@ -349,6 +365,36 @@ public ListClosedWorkflowExecutionsResponse ListClosedWorkflowExecutions(
349365
return impl.ListClosedWorkflowExecutions(listRequest);
350366
}
351367

368+
@Override
369+
public ListWorkflowExecutionsResponse ListWorkflowExecutions(
370+
ListWorkflowExecutionsRequest listRequest)
371+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
372+
ClientVersionNotSupportedError, TException {
373+
return impl.ListWorkflowExecutions(listRequest);
374+
}
375+
376+
@Override
377+
public ListWorkflowExecutionsResponse ScanWorkflowExecutions(
378+
ListWorkflowExecutionsRequest listRequest)
379+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
380+
ClientVersionNotSupportedError, TException {
381+
return impl.ScanWorkflowExecutions(listRequest);
382+
}
383+
384+
@Override
385+
public CountWorkflowExecutionsResponse CountWorkflowExecutions(
386+
CountWorkflowExecutionsRequest countRequest)
387+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
388+
ClientVersionNotSupportedError, TException {
389+
return impl.CountWorkflowExecutions(countRequest);
390+
}
391+
392+
@Override
393+
public GetSearchAttributesResponse GetSearchAttributes()
394+
throws InternalServiceError, ServiceBusyError, ClientVersionNotSupportedError, TException {
395+
return impl.GetSearchAttributes();
396+
}
397+
352398
@Override
353399
public void RespondQueryTaskCompleted(RespondQueryTaskCompletedRequest completeRequest)
354400
throws BadRequestError, InternalServiceError, EntityNotExistsError, TException {
@@ -535,6 +581,13 @@ public void SignalWithStartWorkflowExecution(
535581
impl.SignalWithStartWorkflowExecution(signalWithStartRequest, resultHandler);
536582
}
537583

584+
@Override
585+
public void ResetWorkflowExecution(
586+
ResetWorkflowExecutionRequest resetRequest, AsyncMethodCallback resultHandler)
587+
throws TException {
588+
impl.ResetWorkflowExecution(resetRequest, resultHandler);
589+
}
590+
538591
@Override
539592
public void TerminateWorkflowExecution(
540593
TerminateWorkflowExecutionRequest terminateRequest, AsyncMethodCallback resultHandler)
@@ -556,6 +609,32 @@ public void ListClosedWorkflowExecutions(
556609
impl.ListClosedWorkflowExecutions(listRequest, resultHandler);
557610
}
558611

612+
@Override
613+
public void ListWorkflowExecutions(
614+
ListWorkflowExecutionsRequest listRequest, AsyncMethodCallback resultHandler)
615+
throws TException {
616+
impl.ListWorkflowExecutions(listRequest, resultHandler);
617+
}
618+
619+
@Override
620+
public void ScanWorkflowExecutions(
621+
ListWorkflowExecutionsRequest listRequest, AsyncMethodCallback resultHandler)
622+
throws TException {
623+
impl.ScanWorkflowExecutions(listRequest, resultHandler);
624+
}
625+
626+
@Override
627+
public void CountWorkflowExecutions(
628+
CountWorkflowExecutionsRequest countRequest, AsyncMethodCallback resultHandler)
629+
throws TException {
630+
impl.CountWorkflowExecutions(countRequest, resultHandler);
631+
}
632+
633+
@Override
634+
public void GetSearchAttributes(AsyncMethodCallback resultHandler) throws TException {
635+
impl.GetSearchAttributes();
636+
}
637+
559638
@Override
560639
public void RespondQueryTaskCompleted(
561640
RespondQueryTaskCompletedRequest completeRequest, AsyncMethodCallback resultHandler)

‎src/main/java/com/uber/cadence/internal/testservice/TestWorkflowMutableStateImpl.java‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -347,6 +347,9 @@ private void processDecision(
347347
processRequestCancelExternalWorkflowExecution(
348348
ctx, d.getRequestCancelExternalWorkflowExecutionDecisionAttributes());
349349
break;
350+
case UpsertWorkflowSearchAttributes:
351+
// TODO: https://github.com/uber/cadence-java-client/issues/360
352+
break;
350353
}
351354
}
352355

0 commit comments

Comments
 (0)