|
1 | | -from typing import Any, Callable |
| 1 | +from typing import Any, Callable, Protocol |
2 | 2 |
|
3 | 3 |
|
4 | | -class ProtoTaskHubSidecarServiceStub(object): |
| 4 | +class ProtoTaskHubSidecarServiceStub(Protocol): |
5 | 5 | """A stub class roughly matching the TaskHubSidecarServiceStub generated from the .proto file. |
6 | 6 | Used by Azure Functions during orchestration and entity executions to inject custom behavior, |
7 | 7 | as no real sidecar stub is available. |
8 | 8 | """ |
9 | | - |
10 | | - def __init__(self): |
11 | | - """Constructor. |
12 | | - """ |
13 | | - self.Hello: Callable[..., Any] |
14 | | - self.StartInstance: Callable[..., Any] |
15 | | - self.GetInstance: Callable[..., Any] |
16 | | - self.RewindInstance: Callable[..., Any] |
17 | | - self.WaitForInstanceStart: Callable[..., Any] |
18 | | - self.WaitForInstanceCompletion: Callable[..., Any] |
19 | | - self.RaiseEvent: Callable[..., Any] |
20 | | - self.TerminateInstance: Callable[..., Any] |
21 | | - self.SuspendInstance: Callable[..., Any] |
22 | | - self.ResumeInstance: Callable[..., Any] |
23 | | - self.QueryInstances: Callable[..., Any] |
24 | | - self.PurgeInstances: Callable[..., Any] |
25 | | - self.GetWorkItems: Callable[..., Any] |
26 | | - self.CompleteActivityTask: Callable[..., Any] |
27 | | - self.CompleteOrchestratorTask: Callable[..., Any] |
28 | | - self.CompleteEntityTask: Callable[..., Any] |
29 | | - self.StreamInstanceHistory: Callable[..., Any] |
30 | | - self.CreateTaskHub: Callable[..., Any] |
31 | | - self.DeleteTaskHub: Callable[..., Any] |
32 | | - self.SignalEntity: Callable[..., Any] |
33 | | - self.GetEntity: Callable[..., Any] |
34 | | - self.QueryEntities: Callable[..., Any] |
35 | | - self.CleanEntityStorage: Callable[..., Any] |
36 | | - self.AbandonTaskActivityWorkItem: Callable[..., Any] |
37 | | - self.AbandonTaskOrchestratorWorkItem: Callable[..., Any] |
38 | | - self.AbandonTaskEntityWorkItem: Callable[..., Any] |
| 9 | + Hello: Callable[..., Any] |
| 10 | + StartInstance: Callable[..., Any] |
| 11 | + GetInstance: Callable[..., Any] |
| 12 | + RewindInstance: Callable[..., Any] |
| 13 | + WaitForInstanceStart: Callable[..., Any] |
| 14 | + WaitForInstanceCompletion: Callable[..., Any] |
| 15 | + RaiseEvent: Callable[..., Any] |
| 16 | + TerminateInstance: Callable[..., Any] |
| 17 | + SuspendInstance: Callable[..., Any] |
| 18 | + ResumeInstance: Callable[..., Any] |
| 19 | + QueryInstances: Callable[..., Any] |
| 20 | + PurgeInstances: Callable[..., Any] |
| 21 | + GetWorkItems: Callable[..., Any] |
| 22 | + CompleteActivityTask: Callable[..., Any] |
| 23 | + CompleteOrchestratorTask: Callable[..., Any] |
| 24 | + CompleteEntityTask: Callable[..., Any] |
| 25 | + StreamInstanceHistory: Callable[..., Any] |
| 26 | + CreateTaskHub: Callable[..., Any] |
| 27 | + DeleteTaskHub: Callable[..., Any] |
| 28 | + SignalEntity: Callable[..., Any] |
| 29 | + GetEntity: Callable[..., Any] |
| 30 | + QueryEntities: Callable[..., Any] |
| 31 | + CleanEntityStorage: Callable[..., Any] |
| 32 | + AbandonTaskActivityWorkItem: Callable[..., Any] |
| 33 | + AbandonTaskOrchestratorWorkItem: Callable[..., Any] |
| 34 | + AbandonTaskEntityWorkItem: Callable[..., Any] |
0 commit comments