Support ALL_WITH_PARTIAL_LOCK (#383)

indeedeng · May 14, 2024 · a293ff5 · a293ff5
1 parent bf3ea11
commit a293ff5
Show file tree

Hide file tree

Showing 21 changed files with 1,003 additions and 61 deletions.
diff --git a/docker-compose/ci-cadence-dependencies.yml b/docker-compose/ci-cadence-dependencies.yml
@@ -2,47 +2,22 @@ version: '3.9'
 
 # see .env file for the default value of the environment variables
 services:
-  elasticsearch:
-    container_name: elasticsearch
-    environment:
-      - cluster.routing.allocation.disk.threshold_enabled=true
-      - cluster.routing.allocation.disk.watermark.low=512mb
-      - cluster.routing.allocation.disk.watermark.high=256mb
-      - cluster.routing.allocation.disk.watermark.flood_stage=128mb
-      - discovery.type=single-node
-      - ES_JAVA_OPTS=-Xms256m -Xmx256m
-      - xpack.security.enabled=false
-    image: elasticsearch:${ELASTICSEARCH_VERSION}
-    networks:
-      - testing-network
-    expose:
-      - 9200
   cassandra:
-    image: cassandra:3.11
+    image: cassandra:4.1.1
     ports:
       - "9042:9042"
-    networks:
-      - testing-network
-  zookeeper:
-    image: wurstmeister/zookeeper:3.4.6
-    ports:
-      - "2181:2181"
-    networks:
-      - testing-network
-  kafka:
-    image: wurstmeister/kafka:2.12-2.1.1
-    depends_on:
-      - zookeeper
-    ports:
-      - "9092:9092"
     environment:
-      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092
-      KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092
-      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
+      - "MAX_HEAP_SIZE=256M"
+      - "HEAP_NEWSIZE=128M"
+    healthcheck:
+      test: ["CMD", "cqlsh", "-u cassandra", "-p cassandra" ,"-e describe keyspaces"]
+      interval: 15s
+      timeout: 30s
+      retries: 10
     networks:
-      - testing-network
+      - testing-network  
   cadence:
-    image: ubercadence/server:0.24.0-auto-setup
+    image: ubercadence/server:v1.2.5-auto-setup
     ports:
       - "8000:8000"
       - "8001:8001"
@@ -55,15 +30,15 @@ services:
       - "7833:7833"
     environment:
       - "CASSANDRA_SEEDS=cassandra"
-      - "DYNAMIC_CONFIG_FILE_PATH=config/dynamicconfig/development_es.yaml"
-      - "ENABLE_ES=true"
-      - "ES_SEEDS=elasticsearch"
-      - "ES_VERSION=v7"
-      - "KAFKA_SEEDS=kafka"
+      - "PROMETHEUS_ENDPOINT_0=0.0.0.0:8000"
+      - "PROMETHEUS_ENDPOINT_1=0.0.0.0:8001"
+      - "PROMETHEUS_ENDPOINT_2=0.0.0.0:8002"
+      - "PROMETHEUS_ENDPOINT_3=0.0.0.0:8003"
+      - "DYNAMIC_CONFIG_FILE_PATH=config/dynamicconfig/development.yaml"
+      - "LOG_LEVEL=debug"
     depends_on:
-      - cassandra
-      - kafka
-      - elasticsearch
+      cassandra:
+        condition: service_healthy
     networks:
       - testing-network
   cadence-admin-tools:
@@ -72,7 +47,7 @@ services:
       - cadence
     environment:
       - CADENCE_CLI_ADDRESS=cadence:7933
-    image: ubercadence/cli:0.24.0
+    image: ubercadence/cli:v1.2.6
     networks:
       - testing-network
     stdin_open: true

diff --git a/gen/iwfidl/.openapi-generator/FILES b/gen/iwfidl/.openapi-generator/FILES
@@ -39,6 +39,7 @@ docs/StateMovement.md
 docs/TimerCommand.md
 docs/TimerResult.md
 docs/TimerStatus.md
+docs/TriggerContinueAsNewRequest.md
 docs/WaitUntilApiFailurePolicy.md
 docs/WorkerErrorResponse.md
 docs/WorkflowConditionalClose.md
@@ -116,6 +117,7 @@ model_state_movement.go
 model_timer_command.go
 model_timer_result.go
 model_timer_status.go
+model_trigger_continue_as_new_request.go
 model_wait_until_api_failure_policy.go
 model_worker_error_response.go
 model_workflow_conditional_close.go

diff --git a/gen/iwfidl/README.md b/gen/iwfidl/README.md
@@ -92,6 +92,7 @@ Class | Method | HTTP request | Description
 *DefaultApi* | [**ApiV1WorkflowStateStartPost**](docs/DefaultApi.md#apiv1workflowstatestartpost) | **Post** /api/v1/workflowState/start | for invoking WorkflowState.start API
 *DefaultApi* | [**ApiV1WorkflowStopPost**](docs/DefaultApi.md#apiv1workflowstoppost) | **Post** /api/v1/workflow/stop | stop a workflow
 *DefaultApi* | [**ApiV1WorkflowTimerSkipPost**](docs/DefaultApi.md#apiv1workflowtimerskippost) | **Post** /api/v1/workflow/timer/skip | skip the timer of a workflow
+*DefaultApi* | [**ApiV1WorkflowTriggerContinueAsNewPost**](docs/DefaultApi.md#apiv1workflowtriggercontinueasnewpost) | **Post** /api/v1/workflow/triggerContinueAsNew | trigger ContinueAsNew for a workflow
 *DefaultApi* | [**ApiV1WorkflowWaitForStateCompletionPost**](docs/DefaultApi.md#apiv1workflowwaitforstatecompletionpost) | **Post** /api/v1/workflow/waitForStateCompletion | 
 *DefaultApi* | [**ApiV1WorkflowWorkerRpcPost**](docs/DefaultApi.md#apiv1workflowworkerrpcpost) | **Post** /api/v1/workflowWorker/rpc | for invoking workflow RPC API in the worker
 *DefaultApi* | [**InfoHealthcheckGet**](docs/DefaultApi.md#infohealthcheckget) | **Get** /info/healthcheck | return health info of the server
@@ -131,6 +132,7 @@ Class | Method | HTTP request | Description
  - [TimerCommand](docs/TimerCommand.md)
  - [TimerResult](docs/TimerResult.md)
  - [TimerStatus](docs/TimerStatus.md)
+ - [TriggerContinueAsNewRequest](docs/TriggerContinueAsNewRequest.md)
  - [WaitUntilApiFailurePolicy](docs/WaitUntilApiFailurePolicy.md)
  - [WorkerErrorResponse](docs/WorkerErrorResponse.md)
  - [WorkflowConditionalClose](docs/WorkflowConditionalClose.md)