Skip to content

Commit 9fe1869

Browse files
committed
Don't send approve signal
1 parent 95e36f2 commit 9fe1869

3 files changed

Lines changed: 0 additions & 19 deletions

File tree

nexus_sync_operations/caller/workflows.py

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
from message_passing.introduction import Language
44
from message_passing.introduction.workflows import (
5-
ApproveInput,
65
GetLanguagesInput,
76
SetLanguageInput,
87
SetLanguageUsingActivityInput,
@@ -49,8 +48,3 @@ async def run(self) -> None:
4948
== Language.ARABIC
5049
)
5150
print(f"language changed: {previous_language.name} -> {Language.ARABIC.name}")
52-
53-
# Approve
54-
await nexus_client.execute_operation(
55-
GreetingService.approve, ApproveInput(name="")
56-
)

nexus_sync_operations/handler/service_handler.py

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -7,13 +7,11 @@
77
from __future__ import annotations
88

99
import nexusrpc
10-
from temporalio import nexus
1110
from temporalio.client import Client, WorkflowHandle
1211
from temporalio.common import WorkflowIDConflictPolicy
1312

1413
from message_passing.introduction import Language
1514
from message_passing.introduction.workflows import (
16-
ApproveInput,
1715
GetLanguagesInput,
1816
GreetingWorkflow,
1917
SetLanguageInput,
@@ -78,12 +76,3 @@ async def set_language_using_activity(
7876
return await self.greeting_workflow_handle.execute_update(
7977
GreetingWorkflow.set_language_using_activity, input.language
8078
)
81-
82-
@nexusrpc.handler.sync_operation
83-
async def approve(
84-
self, ctx: nexusrpc.handler.StartOperationContext, input: ApproveInput
85-
) -> None:
86-
await self.greeting_workflow_handle.signal(GreetingWorkflow.approve, input)
87-
self.greeting_workflow_handle = await self._get_workflow_handle(
88-
nexus.client(), nexus.info().task_queue
89-
)

nexus_sync_operations/service.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
from message_passing.introduction import Language
44
from message_passing.introduction.workflows import (
5-
ApproveInput,
65
GetLanguagesInput,
76
SetLanguageInput,
87
SetLanguageUsingActivityInput,
@@ -17,4 +16,3 @@ class GreetingService:
1716
set_language_using_activity: nexusrpc.Operation[
1817
SetLanguageUsingActivityInput, Language
1918
]
20-
approve: nexusrpc.Operation[ApproveInput, None]

0 commit comments

Comments
 (0)