Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
36 changes: 36 additions & 0 deletions crates/client/src/grpc.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1325,6 +1325,15 @@ proxier! {
r.extensions_mut().insert(labels);
}
);
(
update_activity_execution_options,
UpdateActivityExecutionOptionsRequest,
UpdateActivityExecutionOptionsResponse,
|r| {
let labels = namespaced_request!(r);
r.extensions_mut().insert(labels);
}
);
(
pause_activity,
PauseActivityRequest,
Expand All @@ -1334,6 +1343,15 @@ proxier! {
r.extensions_mut().insert(labels);
}
);
(
pause_activity_execution,
PauseActivityExecutionRequest,
PauseActivityExecutionResponse,
|r| {
let labels = namespaced_request!(r);
r.extensions_mut().insert(labels);
}
);
(
unpause_activity,
UnpauseActivityRequest,
Expand All @@ -1343,6 +1361,15 @@ proxier! {
r.extensions_mut().insert(labels);
}
);
(
unpause_activity_execution,
UnpauseActivityExecutionRequest,
UnpauseActivityExecutionResponse,
|r| {
let labels = namespaced_request!(r);
r.extensions_mut().insert(labels);
}
);
(
update_workflow_execution_options,
UpdateWorkflowExecutionOptionsRequest,
Expand All @@ -1361,6 +1388,15 @@ proxier! {
r.extensions_mut().insert(labels);
}
);
(
reset_activity_execution,
ResetActivityExecutionRequest,
ResetActivityExecutionResponse,
|r| {
let labels = namespaced_request!(r);
r.extensions_mut().insert(labels);
}
);
(
delete_worker_deployment,
DeleteWorkerDeploymentRequest,
Expand Down
6 changes: 5 additions & 1 deletion crates/client/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -765,7 +765,11 @@ impl Namespace {
Namespace::Name(n) => (n, "".to_owned()),
Namespace::Id(n) => ("".to_owned(), n),
};
DescribeNamespaceRequest { namespace, id }
DescribeNamespaceRequest {
namespace,
id,
weak_consistency: false,
}
}
}

Expand Down
1 change: 1 addition & 0 deletions crates/client/src/schedules.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1550,6 +1550,7 @@ mod tests {
seconds: 1_700_000_000,
nanos: 0,
}],
state_size_bytes: 0,
}),
};

Expand Down
3 changes: 3 additions & 0 deletions crates/client/src/workflow_handle.rs
Original file line number Diff line number Diff line change
Expand Up @@ -746,6 +746,9 @@ where
name: update.name().to_string(),
args: Some(Payloads { payloads }),
}),
request_id: String::new(),
completion_callbacks: vec![],
links: vec![],
}),
..Default::default()
}
Expand Down

This file was deleted.

23 changes: 22 additions & 1 deletion crates/common/protos/api_upstream/Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ ci-build: install proto http-api-docs
install: grpc-install api-linter-install buf-install

# Run all linters and compile proto files.
proto: grpc http-api-docs
proto: grpc http-api-docs nexus-rpc-yaml
########################################################################

##### Variables ######
Expand Down Expand Up @@ -95,6 +95,11 @@ buf-install:
printf $(COLOR) "Install/update buf..."
go install github.com/bufbuild/buf/cmd/buf@v1.27.0

##### Sync external proto dependencies #####
sync-nexus-annotations:
printf $(COLOR) "Sync nexusannotations from buf.build/temporalio/nexus-annotations..."
buf export buf.build/temporalio/nexus-annotations --output .

##### Linters #####
api-linter:
printf $(COLOR) "Run api-linter..."
Expand All @@ -116,6 +121,22 @@ buf-breaking:
@printf $(COLOR) "Run buf breaking changes check against master branch..."
@(cd $(PROTO_ROOT) && buf breaking --against 'https://github.com/temporalio/api.git#branch=master')

nexus-rpc-yaml: nexus-rpc-yaml-install
printf $(COLOR) "Generate nexus/temporal-proto-models-nexusrpc.yaml..."
mkdir -p nexus
protoc -I $(PROTO_ROOT) \
--nexus-rpc-yaml_opt=nexus-rpc_langs_out=nexus/temporal-proto-models-nexusrpc.yaml \
--nexus-rpc-yaml_opt=python_package_prefix=temporalio.api \
--nexus-rpc-yaml_opt=typescript_package_prefix=@temporalio/api \
--nexus-rpc-yaml_opt=include_operation_tags=exposed \
--nexus-rpc-yaml_out=. \
temporal/api/workflowservice/v1/* \
temporal/api/operatorservice/v1/*

nexus-rpc-yaml-install:
printf $(COLOR) "Build and install protoc-gen-nexus-rpc-yaml..."
@cd cmd/protoc-gen-nexus-rpc-yaml && go install .

##### Clean #####
clean:
printf $(COLOR) "Delete generated go files..."
Expand Down
13 changes: 9 additions & 4 deletions crates/common/protos/api_upstream/buf.lock
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,15 @@ deps:
- remote: buf.build
owner: googleapis
repository: googleapis
commit: 28151c0d0a1641bf938a7672c500e01d
digest: shake256:49215edf8ef57f7863004539deff8834cfb2195113f0b890dd1f67815d9353e28e668019165b9d872395871eeafcbab3ccfdb2b5f11734d3cca95be9e8d139de
commit: 004180b77378443887d3b55cabc00384
digest: shake256:d26c7c2fd95f0873761af33ca4a0c0d92c8577122b6feb74eb3b0a57ebe47a98ab24a209a0e91945ac4c77204e9da0c2de0020b2cedc27bdbcdea6c431eec69b
- remote: buf.build
owner: grpc-ecosystem
repository: grpc-gateway
commit: 048ae6ff94ca4476b3225904b1078fad
digest: shake256:e5250bf2d999516c02206d757502b902e406f35c099d0e869dc3e4f923f6870fe0805a9974c27df0695462937eae90cd4d9db90bb9a03489412560baa74a87b6
commit: 6467306b4f624747aaf6266762ee7a1c
digest: shake256:833d648b99b9d2c18b6882ef41aaeb113e76fc38de20dda810c588d133846e6593b4da71b388bcd921b1c7ab41c7acf8f106663d7301ae9e82ceab22cf64b1b7
- remote: buf.build
owner: temporalio
repository: nexus-annotations
commit: 599b78404fbe4e78b833d527a1d0da40
digest: shake256:1f41ef11ccbf31d7318b0fe1915550ba6567c99dc94694d60b117fc1ffc756290ba9766c58b403986f079e2b861b42538e5f8cf0495f744cd390d223b81854ca
4 changes: 4 additions & 0 deletions crates/common/protos/api_upstream/buf.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -3,11 +3,14 @@ name: buf.build/temporalio/api
deps:
- buf.build/grpc-ecosystem/grpc-gateway
- buf.build/googleapis/googleapis
- buf.build/temporalio/nexus-annotations
build:
excludes:
# Buf won't accept a local dependency on the google protos but we need them
# to run api-linter, so just tell buf it ignore it
- google
# Same for nexusannotations - local copy for api-linter, BSR dep for buf
- nexusannotations
breaking:
use:
- WIRE_JSON
Expand All @@ -18,3 +21,4 @@ lint:
- DEFAULT
ignore:
- google
- cmd
Loading
Loading