Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: cadence-workflow/cadence-java-client
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: v3.4.0
Choose a base ref
...
head repository: cadence-workflow/cadence-java-client
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: master
Choose a head ref

Commits on Oct 4, 2021

  1. Copy the full SHA
    f760fb5 View commit details
  2. release 3.5.0 (#646)

    mkolodezny authored Oct 4, 2021
    Copy the full SHA
    dca853a View commit details

Commits on Nov 19, 2021

  1. Copy the full SHA
    f426c39 View commit details

Commits on Nov 22, 2021

  1. Copy the full SHA
    cff6b0f View commit details
  2. Copy the full SHA
    317135c View commit details

Commits on Nov 23, 2021

  1. Copy the full SHA
    216a287 View commit details
  2. Copy the full SHA
    f90070c View commit details

Commits on Nov 24, 2021

  1. release 3.5.1 (#660)

    mkolodezny authored Nov 24, 2021
    Copy the full SHA
    0109025 View commit details

Commits on Jan 11, 2022

  1. Copy the full SHA
    d5b5e3c View commit details
  2. release 3.6.0 (#665)

    mkolodezny authored Jan 11, 2022
    Copy the full SHA
    e7c6947 View commit details

Commits on Jan 14, 2022

  1. Copy the full SHA
    31524fa View commit details

Commits on Jan 19, 2022

  1. release 3.6.1 (#667)

    mkolodezny authored Jan 19, 2022
    Copy the full SHA
    b72242c View commit details

Commits on Mar 21, 2022

  1. update idls to use refresh tasks API (#668)

    * add refresh tasks API to client
    mkolodezny authored Mar 21, 2022
    Copy the full SHA
    cb5d6ec View commit details

Commits on May 4, 2022

  1. release 3.6.2 (#670)

    mkolodezny authored May 4, 2022
    Copy the full SHA
    7dca5a5 View commit details

Commits on Jun 13, 2022

  1. Copy the full SHA
    2e290a5 View commit details

Commits on Jun 16, 2022

  1. Copy the full SHA
    d67bb44 View commit details

Commits on Jun 17, 2022

  1. Copy the full SHA
    f1dbce5 View commit details
  2. Copy the full SHA
    3f521dd View commit details

Commits on Jun 18, 2022

  1. Copy the full SHA
    7ddf289 View commit details

Commits on Jul 19, 2022

  1. Copy the full SHA
    34a9508 View commit details

Commits on Jul 20, 2022

  1. Copy the full SHA
    8dc4927 View commit details

Commits on Jul 21, 2022

  1. Copy the full SHA
    58c195d View commit details
  2. Copy the full SHA
    d8ff2af View commit details

Commits on Jul 25, 2022

  1. Copy the full SHA
    f50b7db View commit details
  2. Copy the full SHA
    8f2b6b9 View commit details
  3. Copy the full SHA
    d778933 View commit details
  4. Copy the full SHA
    bf0893c View commit details
  5. Copy the full SHA
    3bd2e02 View commit details

Commits on Jul 26, 2022

  1. Copy the full SHA
    f7fd74f View commit details
  2. Copy the full SHA
    ebc37ea View commit details
  3. Copy the full SHA
    d4d746f View commit details
  4. Copy the full SHA
    b839f34 View commit details
  5. Copy the full SHA
    e2f0e9e View commit details
  6. Copy the full SHA
    049a3d6 View commit details
  7. Copy the full SHA
    98dfa55 View commit details

Commits on Jul 27, 2022

  1. Copy the full SHA
    54d886c View commit details
  2. Copy the full SHA
    67f90fb View commit details
  3. Copy the full SHA
    e927f6d View commit details
  4. Copy the full SHA
    2fc28ab View commit details
  5. Copy the full SHA
    50e8830 View commit details
  6. Copy the full SHA
    1551866 View commit details
  7. Copy the full SHA
    c6f41d7 View commit details
  8. Copy the full SHA
    d3a8515 View commit details
  9. Copy the full SHA
    9fd6ad9 View commit details

Commits on Jul 28, 2022

  1. Copy the full SHA
    6e037d0 View commit details
  2. Copy the full SHA
    6d9c640 View commit details
  3. Copy the full SHA
    62a1653 View commit details
  4. Copy the full SHA
    0d6259c View commit details
  5. Copy the full SHA
    5ff4197 View commit details
  6. Copy the full SHA
    015ae0c View commit details
Showing with 33,992 additions and 1,862 deletions.
  1. +84 −36 .buildkite/pipeline.yml
  2. +0 −15 .buildkite/scripts/coverage.sh
  3. +11 −0 .buildkite/scripts/coverage_metadata.sh
  4. +0 −14 .buildkite/scripts/fossa.sh
  5. +12 −0 .buildkite/scripts/lint.sh
  6. +0 −11 .fossa.yml
  7. +6 −0 .github/CODEOWNERS
  8. +21 −0 .github/pull_request_template.md
  9. +18 −0 .github/workflows/breaking_change_pr_template.md
  10. +42 −0 .github/workflows/breaking_change_reminder.yml
  11. +17 −0 .github/workflows/codecov.yml
  12. +1 −0 .gitigmore
  13. +1 −1 .travis.yml
  14. +103 −1 CHANGELOG.md
  15. +46 −30 CONTRIBUTING.md
  16. +3 −3 README.md
  17. +91 −13 build.gradle
  18. +30 −0 codecov.yml
  19. +7 −2 docker/buildkite/Dockerfile
  20. +1 −31 docker/buildkite/docker-compose.yaml
  21. +39 −0 scripts/install-thrift-locally-osx.sh
  22. +1 −1 src/main/idls
  23. +30 −2 src/main/java/com/uber/cadence/activity/Activity.java
  24. +2 −0 src/main/java/com/uber/cadence/activity/ActivityTask.java
  25. +99 −0 src/main/java/com/uber/cadence/client/QueryOptions.java
  26. +319 −1 src/main/java/com/uber/cadence/client/WorkflowClient.java
  27. +2 −1 src/main/java/com/uber/cadence/client/WorkflowClientOptions.java
  28. +25 −5 src/main/java/com/uber/cadence/client/WorkflowStub.java
  29. +3 −0 src/main/java/com/uber/cadence/context/ContextPropagator.java
  30. +10 −2 src/main/java/com/uber/cadence/internal/common/RetryParameters.java
  31. +20 −0 src/main/java/com/uber/cadence/internal/common/StartWorkflowExecutionParameters.java
  32. +35 −262 src/main/java/com/uber/cadence/internal/common/WorkflowExecutionUtils.java
  33. +1,306 −0 src/main/java/com/uber/cadence/internal/compatibility/Thrift2ProtoAdapter.java
  34. +274 −0 src/main/java/com/uber/cadence/internal/compatibility/proto/DecisionMapper.java
  35. +294 −0 src/main/java/com/uber/cadence/internal/compatibility/proto/EnumMapper.java
  36. +75 −0 src/main/java/com/uber/cadence/internal/compatibility/proto/Helpers.java
  37. +868 −0 src/main/java/com/uber/cadence/internal/compatibility/proto/RequestMapper.java
  38. +313 −0 src/main/java/com/uber/cadence/internal/compatibility/proto/TypeMapper.java
  39. +491 −0 src/main/java/com/uber/cadence/internal/compatibility/proto/serviceclient/GrpcServiceStubs.java
  40. +83 −0 src/main/java/com/uber/cadence/internal/compatibility/proto/serviceclient/IGrpcServiceStubs.java
  41. +346 −0 src/main/java/com/uber/cadence/internal/compatibility/thrift/EnumMapper.java
  42. +114 −0 src/main/java/com/uber/cadence/internal/compatibility/thrift/ErrorMapper.java
  43. +49 −0 src/main/java/com/uber/cadence/internal/compatibility/thrift/Helpers.java
  44. +1,179 −0 src/main/java/com/uber/cadence/internal/compatibility/thrift/HistoryMapper.java
  45. +456 −0 src/main/java/com/uber/cadence/internal/compatibility/thrift/ResponseMapper.java
  46. +689 −0 src/main/java/com/uber/cadence/internal/compatibility/thrift/TypeMapper.java
  47. +6 −0 src/main/java/com/uber/cadence/internal/context/ContextThreadLocal.java
  48. +9 −0 src/main/java/com/uber/cadence/internal/external/GenericWorkflowClientExternal.java
  49. +133 −23 src/main/java/com/uber/cadence/internal/external/GenericWorkflowClientExternalImpl.java
  50. +2 −0 src/main/java/com/uber/cadence/internal/external/ManualActivityCompletionClientImpl.java
  51. +0 −7 src/main/java/com/uber/cadence/internal/logging/LoggerTag.java
  52. +70 −0 src/main/java/com/uber/cadence/internal/metrics/ClientVersionEmitter.java
  53. +3 −10 src/main/java/com/uber/cadence/internal/metrics/MetricsTag.java
  54. +25 −0 src/main/java/com/uber/cadence/internal/metrics/MetricsTagValue.java
  55. +6 −16 src/main/java/com/uber/cadence/internal/metrics/MetricsType.java
  56. +2 −2 src/main/java/com/uber/cadence/internal/metrics/NoopScope.java
  57. +2 −2 src/main/java/com/uber/cadence/internal/metrics/ReplayAwareScope.java
  58. +4 −0 src/main/java/com/uber/cadence/internal/metrics/ServiceMethod.java
  59. +0 −9 src/main/java/com/uber/cadence/internal/replay/ActivityDecisionStateMachine.java
  60. +0 −12 src/main/java/com/uber/cadence/internal/replay/ChildWorkflowDecisionStateMachine.java
  61. +71 −8 src/main/java/com/uber/cadence/internal/replay/ClockDecisionContext.java
  62. +3 −1 src/main/java/com/uber/cadence/internal/replay/ContinueAsNewWorkflowExecutionParameters.java
  63. +7 −0 src/main/java/com/uber/cadence/internal/replay/DecisionContext.java
  64. +23 −1 src/main/java/com/uber/cadence/internal/replay/DecisionContextImpl.java
  65. +40 −3 src/main/java/com/uber/cadence/internal/replay/DecisionsHelper.java
  66. +2 −8 src/main/java/com/uber/cadence/internal/replay/HistoryHelper.java
  67. +25 −5 src/main/java/com/uber/cadence/internal/replay/MarkerHandler.java
  68. +4 −33 src/main/java/com/uber/cadence/internal/replay/QueryWorkflowParameters.java
  69. +13 −23 src/main/java/com/uber/cadence/internal/replay/ReplayDecider.java
  70. +0 −9 src/main/java/com/uber/cadence/internal/replay/SignalDecisionStateMachine.java
  71. +12 −1 src/main/java/com/uber/cadence/internal/replay/SignalExternalWorkflowParameters.java
  72. +0 −7 src/main/java/com/uber/cadence/internal/replay/TimerDecisionStateMachine.java
  73. +9 −6 src/main/java/com/uber/cadence/internal/replay/WorkflowContext.java
  74. +30 −10 src/main/java/com/uber/cadence/internal/shadowing/ScanWorkflowActivityImpl.java
  75. +25 −1 src/main/java/com/uber/cadence/internal/sync/ActivityInvocationHandler.java
  76. +20 −0 src/main/java/com/uber/cadence/internal/sync/ChildWorkflowStubImpl.java
  77. +17 −1 src/main/java/com/uber/cadence/internal/sync/DeterministicRunnerImpl.java
  78. +20 −0 src/main/java/com/uber/cadence/internal/sync/ExternalWorkflowStubImpl.java
  79. +4 −3 src/main/java/com/uber/cadence/internal/sync/POJOActivityTaskHandler.java
  80. +7 −2 src/main/java/com/uber/cadence/internal/sync/POJOWorkflowImplementationFactory.java
  81. +16 −3 src/main/java/com/uber/cadence/internal/sync/SignalWithStartBatchRequest.java
  82. +0 −5 src/main/java/com/uber/cadence/internal/sync/SimulatedTimeoutExceptionInternal.java
  83. +65 −1 src/main/java/com/uber/cadence/internal/sync/SyncDecisionContext.java
  84. +8 −2 src/main/java/com/uber/cadence/internal/sync/SyncWorkflow.java
  85. +1 −1 src/main/java/com/uber/cadence/internal/sync/SyncWorkflowDefinition.java
  86. +2 −14 src/main/java/com/uber/cadence/internal/sync/SyncWorkflowWorker.java
  87. +96 −13 src/main/java/com/uber/cadence/internal/sync/TestActivityEnvironmentInternal.java
  88. +132 −16 src/main/java/com/uber/cadence/internal/sync/TestWorkflowEnvironmentInternal.java
  89. +126 −1 src/main/java/com/uber/cadence/internal/sync/WorkflowClientInternal.java
  90. +12 −0 src/main/java/com/uber/cadence/internal/sync/WorkflowInfoImpl.java
  91. +6 −33 src/main/java/com/uber/cadence/internal/sync/WorkflowInternal.java
  92. +28 −0 src/main/java/com/uber/cadence/internal/sync/WorkflowInvocationHandler.java
  93. +2 −2 src/main/java/com/uber/cadence/internal/sync/WorkflowQueueImpl.java
  94. +0 −15 src/main/java/com/uber/cadence/internal/sync/WorkflowRetryerInternal.java
  95. +5 −2 src/main/java/com/uber/cadence/internal/sync/WorkflowRunnable.java
  96. +96 −12 src/main/java/com/uber/cadence/internal/sync/WorkflowStubImpl.java
  97. +1 −0 src/main/java/com/uber/cadence/internal/sync/WorkflowThreadImpl.java
  98. +1 −0 src/main/java/com/uber/cadence/internal/testservice/StateMachines.java
  99. +96 −0 src/main/java/com/uber/cadence/internal/testservice/TestWorkflowMutableStateAttrUtil.java
  100. +10 −81 src/main/java/com/uber/cadence/internal/testservice/TestWorkflowMutableStateImpl.java
  101. +110 −3 src/main/java/com/uber/cadence/internal/testservice/TestWorkflowService.java
  102. +58 −39 src/main/java/com/uber/cadence/internal/testservice/TestWorkflowStoreImpl.java
  103. +168 −0 src/main/java/com/uber/cadence/internal/tracing/TracingPropagator.java
  104. +18 −2 src/main/java/com/uber/cadence/internal/worker/ActivityPollTask.java
  105. +17 −2 src/main/java/com/uber/cadence/internal/worker/ActivityWorker.java
  106. +54 −31 src/main/java/com/uber/cadence/internal/worker/LocalActivityWorker.java
  107. +5 −0 src/main/java/com/uber/cadence/internal/worker/PollDecisionTaskDispatcher.java
  108. +5 −0 src/main/java/com/uber/cadence/internal/worker/PollTaskExecutor.java
  109. +45 −11 src/main/java/com/uber/cadence/internal/worker/Poller.java
  110. +103 −0 src/main/java/com/uber/cadence/internal/worker/PollerAutoScalerOptions.java
  111. +44 −2 src/main/java/com/uber/cadence/internal/worker/PollerOptions.java
  112. +18 −2 src/main/java/com/uber/cadence/internal/worker/SingleWorkerOptions.java
  113. +2 −0 src/main/java/com/uber/cadence/internal/worker/TaskExecutor.java
  114. +33 −0 src/main/java/com/uber/cadence/internal/worker/TaskListKind.java
  115. +0 −6 src/main/java/com/uber/cadence/internal/worker/Throttler.java
  116. +71 −0 src/main/java/com/uber/cadence/internal/worker/WorkerShutDownHandler.java
  117. +18 −4 src/main/java/com/uber/cadence/internal/worker/WorkflowPollTask.java
  118. +4 −1 src/main/java/com/uber/cadence/internal/worker/WorkflowPollTaskFactory.java
  119. +6 −1 src/main/java/com/uber/cadence/internal/worker/WorkflowWorker.java
  120. +42 −0 src/main/java/com/uber/cadence/internal/worker/autoscaler/AutoScaler.java
  121. +45 −0 src/main/java/com/uber/cadence/internal/worker/autoscaler/AutoScalerFactory.java
  122. +48 −0 src/main/java/com/uber/cadence/internal/worker/autoscaler/NoopAutoScaler.java
  123. +111 −0 src/main/java/com/uber/cadence/internal/worker/autoscaler/PollerAutoScaler.java
  124. +29 −0 src/main/java/com/uber/cadence/internal/worker/autoscaler/PollerUsage.java
  125. +48 −0 src/main/java/com/uber/cadence/internal/worker/autoscaler/PollerUsageEstimator.java
  126. +46 −0 src/main/java/com/uber/cadence/internal/worker/autoscaler/Recommender.java
  127. +28 −0 src/main/java/com/uber/cadence/internal/worker/autoscaler/ResizableSemaphore.java
  128. +41 −0 src/main/java/com/uber/cadence/migration/MigrationActivities.java
  129. +57 −0 src/main/java/com/uber/cadence/migration/MigrationActivitiesImpl.java
  130. +487 −0 src/main/java/com/uber/cadence/migration/MigrationIWorkflowService.java
  131. +232 −0 src/main/java/com/uber/cadence/migration/MigrationInterceptor.java
  132. +36 −0 src/main/java/com/uber/cadence/migration/MigrationInterceptorFactory.java
  133. +30 −0 src/main/java/com/uber/cadence/migration/StartWorkflowInNewResponse.java
  134. +18 −8 src/main/java/com/uber/cadence/reporter/CadenceClientStatsReporter.java
  135. +76 −31 src/main/java/com/uber/cadence/serviceclient/ClientOptions.java
  136. +18 −0 src/main/java/com/uber/cadence/serviceclient/IWorkflowService.java
  137. +707 −0 src/main/java/com/uber/cadence/serviceclient/IWorkflowServiceBase.java
  138. +389 −84 src/main/java/com/uber/cadence/serviceclient/WorkflowServiceTChannel.java
  139. +6 −3 src/main/java/com/uber/cadence/serviceclient/auth/AdminJwtAuthorizationProvider.java
  140. +65 −0 src/main/java/com/uber/cadence/serviceclient/auth/OAuthAuthorizationProvider.java
  141. +8 −2 src/main/java/com/uber/cadence/testing/TestWorkflowEnvironment.java
  142. +11 −0 src/main/java/com/uber/cadence/worker/Worker.java
  143. +11 −10 src/main/java/com/uber/cadence/worker/WorkerFactory.java
  144. +26 −2 src/main/java/com/uber/cadence/worker/WorkerOptions.java
  145. +35 −3 src/main/java/com/uber/cadence/worker/WorkflowImplementationOptions.java
  146. +2 −0 src/main/java/com/uber/cadence/workflow/ChildWorkflowStub.java
  147. +2 −0 src/main/java/com/uber/cadence/workflow/ExternalWorkflowStub.java
  148. +68 −0 src/main/java/com/uber/cadence/workflow/SignalOptions.java
  149. +6 −0 src/main/java/com/uber/cadence/workflow/WorkflowInfo.java
  150. +37 −4 src/main/java/com/uber/cadence/workflow/WorkflowInterceptor.java
  151. +16 −4 src/main/java/com/uber/cadence/workflow/WorkflowInterceptorBase.java
  152. +1 −3 src/main/java/com/uber/cadence/workflow/WorkflowUtils.java
  153. +137 −0 src/test/java/com/uber/cadence/FakeWorkflowServiceRule.java
  154. +10 −3 src/test/java/com/uber/cadence/RegisterTestDomain.java
  155. +3 −3 src/test/java/com/uber/cadence/activity/LocalActivityContextPropagationTest.java
  156. +115 −0 src/test/java/com/uber/cadence/activity/LocalActivityOptionsEqualsTest.java
  157. +75 −0 src/test/java/com/uber/cadence/activity/LocalActivityOptionsTest.java
  158. +114 −0 src/test/java/com/uber/cadence/client/ActivityCompletionExceptionTest.java
  159. +4 −1 src/test/java/com/uber/cadence/converter/JsonDataConverterTest.java
  160. +69 −0 src/test/java/com/uber/cadence/internal/common/RetryParametersTest.java
  161. +128 −0 src/test/java/com/uber/cadence/internal/common/StartWorkflowExecutionParametersTest.java
  162. +87 −0 src/test/java/com/uber/cadence/internal/common/TerminateWorkflowExecutionParametersTest.java
  163. +472 −0 src/test/java/com/uber/cadence/internal/common/WorkflowExecutionUtilsTest.java
  164. +379 −0 src/test/java/com/uber/cadence/internal/compatibility/EnumMapperTest.java
  165. +91 −0 src/test/java/com/uber/cadence/internal/compatibility/MapperTestUtil.java
  166. +1,425 −0 src/test/java/com/uber/cadence/internal/compatibility/ProtoObjects.java
  167. +1,082 −0 src/test/java/com/uber/cadence/internal/compatibility/Thrift2ProtoAdapterTest.java
  168. +1,154 −0 src/test/java/com/uber/cadence/internal/compatibility/ThriftObjects.java
  169. +142 −0 src/test/java/com/uber/cadence/internal/compatibility/proto/DecisionMapperTest.java
  170. +256 −0 src/test/java/com/uber/cadence/internal/compatibility/proto/RequestMapperTest.java
  171. +157 −0 src/test/java/com/uber/cadence/internal/compatibility/proto/TypeMapperTest.java
  172. +187 −0 src/test/java/com/uber/cadence/internal/compatibility/thrift/ErrorMapperTest.java
  173. +339 −0 src/test/java/com/uber/cadence/internal/compatibility/thrift/HistoryMapperEventTest.java
  174. +198 −0 src/test/java/com/uber/cadence/internal/compatibility/thrift/ResponseMapperTest.java
  175. +218 −0 src/test/java/com/uber/cadence/internal/compatibility/thrift/TypeMapperTest.java
  176. +1,773 −0 src/test/java/com/uber/cadence/internal/logging/ReplayAwareLoggerTest.java
  177. +108 −0 src/test/java/com/uber/cadence/internal/replay/ContinueAsNewWorkflowExecutionParametersTest.java
  178. +116 −0 src/test/java/com/uber/cadence/internal/replay/DecisionsHelperTest.java
  179. +165 −0 src/test/java/com/uber/cadence/internal/replay/ExecuteActivityParametersTest.java
  180. +38 −0 src/test/java/com/uber/cadence/internal/replay/QueryWorkflowParametersTest.java
  181. +241 −0 ...test/java/com/uber/cadence/internal/replay/ReplaceDeciderDecisionTaskWithHistoryIteratorTest.java
  182. +2 −4 src/test/java/com/uber/cadence/internal/replay/ReplayDeciderCacheTests.java
  183. +1 −1 src/test/java/com/uber/cadence/internal/replay/ReplayDeciderTaskHandlerTests.java
  184. +191 −0 src/test/java/com/uber/cadence/internal/replay/SignalExternalWorkflowParametersTest.java
  185. +175 −0 src/test/java/com/uber/cadence/internal/replay/StartChildWorkflowExecutionParametersTest.java
  186. +1 −1 src/test/java/com/uber/cadence/internal/shadowing/ReplayWorkflowActivityTest.java
  187. +2 −2 src/test/java/com/uber/cadence/internal/shadowing/ScanWorkflowActivityTest.java
  188. +3 −3 src/test/java/com/uber/cadence/internal/sync/DeterministicRunnerTest.java
  189. +215 −0 src/test/java/com/uber/cadence/internal/sync/PromiseTest.java
  190. +1 −1 src/test/java/com/uber/cadence/internal/sync/SyncDecisionContextTest.java
  191. +358 −0 src/test/java/com/uber/cadence/internal/sync/TestActivityEnvironmentInternalTest.java
  192. +696 −0 src/test/java/com/uber/cadence/internal/sync/TestWorkflowEnvironmentInternalTest.java
  193. +538 −0 src/test/java/com/uber/cadence/internal/sync/WorkflowClientInternalTest.java
  194. +170 −0 src/test/java/com/uber/cadence/internal/sync/WorkflowInternalQueueTest.java
  195. +229 −0 src/test/java/com/uber/cadence/internal/sync/WorkflowStubImplTest.java
  196. +1 −1 src/test/java/com/uber/cadence/internal/testing/ActivityTestingTest.java
  197. +45 −18 src/test/java/com/uber/cadence/internal/testing/WorkflowTestingTest.java
  198. +98 −0 ...ternal/testservice/TestWorkflowMutableStateAttrUtil_inheritUnsetPropertiesFromParentWorkflow.java
  199. +124 −0 ...dence/internal/testservice/TestWorkflowMutableStateAttrUtil_validateScheduleActivityTaskTest.java
  200. +101 −0 .../internal/testservice/TestWorkflowMutableStateAttrUtil_validateStartChildExecutionAttributes.java
  201. +535 −0 src/test/java/com/uber/cadence/internal/tracing/StartWorkflowTest.java
  202. +67 −0 src/test/java/com/uber/cadence/internal/tracing/TracingPropagatorTest.java
  203. +194 −0 src/test/java/com/uber/cadence/internal/worker/ActivityPollTaskTest.java
  204. +54 −0 src/test/java/com/uber/cadence/internal/worker/CircularLongBufferTest.java
  205. +69 −0 src/test/java/com/uber/cadence/internal/worker/LocallyDispatchedActivityPollTaskTest.java
  206. +0 −1 src/test/java/com/uber/cadence/internal/worker/PollDecisionTaskDispatcherTests.java
  207. +106 −0 src/test/java/com/uber/cadence/internal/worker/PollerAutoScalerOptionsTest.java
  208. +104 −0 src/test/java/com/uber/cadence/internal/worker/PollerOptionsTest.java
  209. +32 −0 src/test/java/com/uber/cadence/internal/worker/TaskListKindTest.java
  210. +104 −0 src/test/java/com/uber/cadence/internal/worker/ThrottlerTest.java
  211. +66 −0 src/test/java/com/uber/cadence/internal/worker/WorkerShutDownHandlerTest.java
  212. +212 −0 src/test/java/com/uber/cadence/internal/worker/WorkflowPollTaskTest.java
  213. +117 −0 src/test/java/com/uber/cadence/internal/worker/autoscaler/PollerAutoScalerTest.java
  214. +91 −0 src/test/java/com/uber/cadence/internal/worker/autoscaler/PollerUsageEstimatorTest.java
  215. +69 −0 src/test/java/com/uber/cadence/internal/worker/autoscaler/RecommenderTest.java
  216. +41 −0 src/test/java/com/uber/cadence/internal/worker/autoscaler/ResizableSemaphoreTest.java
  217. +12 −12 src/test/java/com/uber/cadence/metrics/ReplayAwareScopeTest.java
  218. +1,230 −0 src/test/java/com/uber/cadence/migration/MigrationIWorkflowServiceTest.java
  219. +60 −0 src/test/java/com/uber/cadence/serviceclient/ClientOptionsTest.java
  220. +340 −0 src/test/java/com/uber/cadence/serviceclient/IWorkflowServiceBaseTest.java
  221. +3,410 −0 src/test/java/com/uber/cadence/serviceclient/WorkflowServiceTChannelTest.java
  222. +5 −0 src/test/java/com/uber/cadence/serviceclient/auth/AdminJwtAuthorizationProviderTest.java
  223. +46 −0 src/test/java/com/uber/cadence/serviceclient/auth/OAuthAuthorizationProviderTest.java
  224. +238 −0 src/test/java/com/uber/cadence/testUtils/CadenceTestContext.java
  225. +307 −0 src/test/java/com/uber/cadence/testUtils/CadenceTestRule.java
  226. +24 −0 src/test/java/com/uber/cadence/testUtils/RequiresDockerService.java
  227. +24 −0 src/test/java/com/uber/cadence/testUtils/RequiresTestService.java
  228. +38 −0 src/test/java/com/uber/cadence/testUtils/TestEnvironment.java
  229. +147 −0 src/test/java/com/uber/cadence/testing/TestWorkflowEnvironmentTest.java
  230. +4 −4 src/test/java/com/uber/cadence/testing/WorkflowShadowerTest.java
  231. +1 −1 src/test/java/com/uber/cadence/worker/CleanWorkerShutdownTest.java
  232. +4 −4 src/test/java/com/uber/cadence/worker/ShadowingWorkerTest.java
  233. +10 −11 src/test/java/com/uber/cadence/worker/StickyWorkerTest.java
  234. +1 −1 src/test/java/com/uber/cadence/worker/WorkerStressTests.java
  235. +99 −0 src/test/java/com/uber/cadence/workflow/CrossDomainWorkflowTest.java
  236. +21 −4 src/test/java/com/uber/cadence/workflow/LoggerTest.java
  237. +274 −0 src/test/java/com/uber/cadence/workflow/ManualActivityCompletionWorkflowTest.java
  238. +5 −9 src/test/java/com/uber/cadence/workflow/MetricsTest.java
  239. +120 −0 src/test/java/com/uber/cadence/workflow/TestEnvironmentWorkflowTest.java
  240. +194 −0 src/test/java/com/uber/cadence/workflow/WorkflowMigrationTest.java
  241. +116 −0 src/test/java/com/uber/cadence/workflow/WorkflowReplayTest.java
  242. +354 −684 src/test/java/com/uber/cadence/workflow/WorkflowTest.java
  243. +20 −0 src/test/java/com/uber/cadence/workflow/interceptors/SignalWorkflowInterceptor.java
  244. +236 −0 src/test/java/com/uber/cadence/workflow/interceptors/TracingWorkflowInterceptorFactory.java
  245. +82 −0 src/test/resources/docker-compose.yml
  246. +1 −0 src/test/resources/testGetVersionHistoryWithCadenceChangeVersion.json
120 changes: 84 additions & 36 deletions .buildkite/pipeline.yml
Original file line number Diff line number Diff line change
@@ -1,67 +1,115 @@
container:
kubernetes: &kubernetes
gitEnvFrom:
- secretRef:
name: oss-github-ssh-credentials
sidecars:
- image: us-west1-docker.pkg.dev/ci-compute/buildkite-images/buildkite-dind:v1
volumeMounts:
- mountPath: /var/run/
name: docker-sock
securityContext:
privileged: true
allowPrivilegeEscalation: true
mirrorVolumeMounts: true # CRITICAL: this must be at the same indentation level as sidecars
podSpec: &podSpec
containers:
- &commandContainer
image: us-west1-docker.pkg.dev/ci-compute/buildkite-images/buildkite-command-container:v2
command:
- |-
echo "Command step was not overridden."
exit 1
volumeMounts:
- mountPath: /var/run/
name: docker-sock
resources:
requests:
cpu: 7500m
memory: 30G
volumes:
- name: docker-sock
emptyDir: {}

agents:
queue: buildkite-gcp

steps:
- label: "fossa analyze"
agents:
queue: "init"
docker: "*"
command: ".buildkite/scripts/fossa.sh"
- label: "Lint Check"
plugins:
- kubernetes:
<<: *kubernetes
podSpec:
<<: *podSpec
containers:
- <<: *commandContainer
command:
- |-
.buildkite/scripts/lint.sh
- docker-compose#v3.0.0:
run: unit-test-test-service
config: docker/buildkite/docker-compose.yaml

- label: ":java: Unit test with test services"
agents:
queue: "workers"
docker: "*"
command: "./gradlew --no-daemon test jacocoTestReport"
artifact_paths:
- "build/reports/jacoco/test/*.xml"
timeout_in_minutes: 15
- "build/reports/jacoco/test/jacocoTestReport.xml"
- "build/reports/metadata.txt"
timeout_in_minutes: 30
retry:
automatic:
- exit_status: "*"
limit: 3
plugins:
- kubernetes:
<<: *kubernetes
podSpec:
<<: *podSpec
containers:
- <<: *commandContainer
command:
- |-
./gradlew --no-daemon test jacocoTestReport
.buildkite/scripts/coverage_metadata.sh build/reports/metadata.txt
- docker-compose#v3.0.0:
run: unit-test-test-service
config: docker/buildkite/docker-compose.yaml

- label: ":java: Unit test with docker services sticky on"
agents:
queue: "workers"
docker: "*"
command: "./gradlew --no-daemon test"
timeout_in_minutes: 15
timeout_in_minutes: 30
retry:
automatic:
- exit_status: "*"
limit: 3
plugins:
- kubernetes:
<<: *kubernetes
podSpec:
<<: *podSpec
containers:
- <<: *commandContainer
command:
- |-
./gradlew --no-daemon test
- docker-compose#v3.0.0:
run: unit-test-docker-sticky-on
config: docker/buildkite/docker-compose.yaml

- label: ":java: Unit test with docker services sticky off"
agents:
queue: "workers"
docker: "*"
command: "./gradlew --no-daemon test"
timeout_in_minutes: 15
timeout_in_minutes: 30
retry:
automatic:
- exit_status: "*"
limit: 3
plugins:
- kubernetes:
<<: *kubernetes
podSpec:
<<: *podSpec
containers:
- <<: *commandContainer
command:
- |-
./gradlew --no-daemon test
- docker-compose#v3.0.0:
run: unit-test-docker-sticky-off
config: docker/buildkite/docker-compose.yaml
- wait

- label: ":java: Report test coverage"
agents:
queue: "workers"
docker: "*"
command: ".buildkite/scripts/coverage.sh"
retry:
automatic:
- exit_status: "*"
limit: 3
plugins:
- docker-compose#v3.0.0:
run: test-coverage-report
config: docker/buildkite/docker-compose.yaml
15 changes: 0 additions & 15 deletions .buildkite/scripts/coverage.sh

This file was deleted.

11 changes: 11 additions & 0 deletions .buildkite/scripts/coverage_metadata.sh
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
#!/bin/sh
set -ex
# This script generates coverage metadata for the coverage report.
# Output is used by SonarQube integration in Uber and not used by OS repo coverage tool itself.
# Example output:
# commit-sha: 6953daa563e8e44512bc349c9608484cfd4ec4ff
# timestamp: 2024-03-04T19:29:16Z
output_path="$1"
echo "commit-sha: $(git rev-parse HEAD)" > "$output_path"
echo "timestamp: $(date -u +%Y-%m-%dT%H:%M:%SZ)" >> "$output_path"
echo "Coverage metadata written to $output_path"
14 changes: 0 additions & 14 deletions .buildkite/scripts/fossa.sh

This file was deleted.

12 changes: 12 additions & 0 deletions .buildkite/scripts/lint.sh
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
#!/bin/sh

set -ex

./gradlew goJF

if [ -n "$(git status --porcelain)" ]; then
echo "There are changes after linting (used goJF) cmd: ./gradlew goJF"
echo "Please rerun the command and commit the changes"
git status --porcelain
exit 1
fi
11 changes: 0 additions & 11 deletions .fossa.yml

This file was deleted.

6 changes: 6 additions & 0 deletions .github/CODEOWNERS
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
# This is a comment.
# Each line is a file pattern followed by one or more owners.
# Order is important; the last matching pattern takes the most
# precedence.

* @Groxx @abhishekj720 @natemort @shijiesheng @dkrotx @taylanisikdemir @demirkayaender
21 changes: 21 additions & 0 deletions .github/pull_request_template.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,21 @@
<!-- Describe what has changed in this PR -->
**What changed?**


<!-- Tell your future self why have you made these changes -->
**Why?**


<!-- How have you verified this change? Tested locally? Added a unit test? Checked in staging env? -->
**How did you test it?**


<!-- Assuming the worst case, what can be broken when deploying this change to production? -->
<!-- If you are upgrading a dependency, please mention the major version change. Read changelogs and capture any breaking changes here. -->
**Potential risks**

<!-- Is it notable for release? e.g. schema updates, configuration or data migration required? If so, please mention it, and also update CHANGELOG.md -->
**Release notes**

<!-- Is there any documentation updates should be made for config, https://cadenceworkflow.io/docs/operation-guide/setup/ ? If so, please open an PR in https://github.com/uber/cadence-docs -->
**Documentation Changes**
18 changes: 18 additions & 0 deletions .github/workflows/breaking_change_pr_template.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
**Detailed Description**
[In-depth description of the changes made to the interfaces, specifying new fields, removed fields, or modified data structures]

**Impact Analysis**
- **Backward Compatibility**: [Analysis of backward compatibility]
- **Forward Compatibility**: [Analysis of forward compatibility]

**Testing Plan**
- **Unit Tests**: [Do we have unit test covering the change?]
- **Persistence Tests**: [If the change is related to a data type which is persisted, do we have persistence tests covering the change?]
- **Integration Tests**: [Do we have integration test covering the change?]
- **Compatibility Tests**: [Have we done tests to test the backward and forward compatibility?]

**Rollout Plan**
- What is the rollout plan?
- Does the order of deployment matter?
- Is it safe to rollback? Does the order of rollback matter?
- Is there a kill switch to mitigate the impact immediately?
42 changes: 42 additions & 0 deletions .github/workflows/breaking_change_reminder.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,42 @@
name: Workflow for Breaking Change Reminder
on:
pull_request:
paths:
# below file(s) do not cover all the exposed types/funcs, but it's a good start to detect potentially breaking changes
- src/main/java/com/uber/cadence/client/WorkflowStub.java

jobs:
breaking-change-pr-template-reminder:
runs-on: ubuntu-latest

steps:
- name: Checkout
uses: actions/checkout@v4
with:
fetch-depth: 0

- name: Fail if PR description is missing breaking change template
if: steps.pr-changes.outputs.changes != '[]'
run: |
PR_NUMBER=${{ github.event.pull_request.number }}
PR_URL="https://api.github.com/repos/${{ github.repository }}/pulls/${PR_NUMBER}"
BODY=$(curl $PR_URL | jq '.body')
CHECKLIST=(
"Detailed Description"
"Impact Analysis"
"Testing Plan"
"Rollout Plan"
)
TEMPLATE=$(cat .github/workflows/breaking_change_pr_template.md)
for i in "${CHECKLIST[@]}"; do
if [[ "$BODY" == *"$i"* ]]; then
continue
else
echo "Potential breaking changes detected! Please update the PR description to include following template:"
echo "---"
echo "$TEMPLATE"
echo "---"
exit 1
fi
done
17 changes: 17 additions & 0 deletions .github/workflows/codecov.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
name: Workflow for Codecov
on: [push, pull_request]
jobs:
run:
runs-on: ubuntu-latest
steps:
- name: Checkout
uses: actions/checkout@v4
with:
submodules: 'true'
- name: Install dependencies, run tests, and collect coverage
run: docker compose -f docker/buildkite/docker-compose.yaml run unit-test-test-service
- name: Upload coverage to Codecov
uses: codecov/codecov-action@v4
env:
CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
slug: cadence-workflow/cadence-java-client
1 change: 1 addition & 0 deletions .gitigmore
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
.dependencies
2 changes: 1 addition & 1 deletion .travis.yml
Original file line number Diff line number Diff line change
@@ -7,7 +7,7 @@ env:

before_install:
- pushd /tmp
- wget https://www-us.apache.org/dist/thrift/0.9.3/thrift-0.9.3.tar.gz
- wget https://archive.apache.org/dist/thrift/0.9.3/thrift-0.9.3.tar.gz
- tar xfz thrift-0.9.3.tar.gz
- cd thrift-0.9.3
- ./configure --enable-libs=no --enable-tests=no --enable-tutorial=no --with-cpp=no --with-c_glib=no --with-java=yes --with-ruby=no --with-erlang=no --with-go=no --with-nodejs=no --with-python=no
Loading