diff --git a/CHANGELOG.md b/CHANGELOG.md index a80efab..b646071 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -11,6 +11,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 - Retry policies for activities and sub-orchestrations ([#11](https://github.com/microsoft/durabletask-python/pull/11)) - contributed by [@DeepanshuA](https://github.com/DeepanshuA) +### Fixed + +- Fix try/except in orchestrator functions not being handled correctly ([#21](https://github.com/microsoft/durabletask-python/pull/21)) - by [@cgillum](https://github.com/cgillum) +- Updated `durabletask-protobuf` submodule reference to latest distributed tracing commit - by [@cgillum](https://github.com/cgillum) + ## v0.1.0a5 ### New diff --git a/README.md b/README.md index 1c300fb..22b3c44 100644 --- a/README.md +++ b/README.md @@ -170,7 +170,7 @@ git submodule update --init Once the submodule is available, the corresponding source code can be regenerated using the following command from the project root: ```sh -make proto-gen +make gen-proto ``` ### Running unit tests diff --git a/durabletask/internal/orchestrator_service_pb2.py b/durabletask/internal/orchestrator_service_pb2.py index 107e209..cd1ef16 100644 --- a/durabletask/internal/orchestrator_service_pb2.py +++ b/durabletask/internal/orchestrator_service_pb2.py @@ -12,11 +12,12 @@ from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2 +from google.protobuf import duration_pb2 as google_dot_protobuf_dot_duration__pb2 from google.protobuf import wrappers_pb2 as google_dot_protobuf_dot_wrappers__pb2 from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1aorchestrator_service.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/wrappers.proto\x1a\x1bgoogle/protobuf/empty.proto\"^\n\x15OrchestrationInstance\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x31\n\x0b\x65xecutionId\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\xc2\x01\n\x0f\x41\x63tivityRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12-\n\x07version\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x35\n\x15orchestrationInstance\x18\x04 \x01(\x0b\x32\x16.OrchestrationInstance\x12\x0e\n\x06taskId\x18\x05 \x01(\x05\"\x91\x01\n\x10\x41\x63tivityResponse\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0e\n\x06taskId\x18\x02 \x01(\x05\x12,\n\x06result\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x0e\x66\x61ilureDetails\x18\x04 \x01(\x0b\x32\x13.TaskFailureDetails\"\xb2\x01\n\x12TaskFailureDetails\x12\x11\n\terrorType\x18\x01 \x01(\t\x12\x14\n\x0c\x65rrorMessage\x18\x02 \x01(\t\x12\x30\n\nstackTrace\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12)\n\x0cinnerFailure\x18\x04 \x01(\x0b\x32\x13.TaskFailureDetails\x12\x16\n\x0eisNonRetriable\x18\x05 \x01(\x08\"\xbf\x01\n\x12ParentInstanceInfo\x12\x17\n\x0ftaskScheduledId\x18\x01 \x01(\x05\x12*\n\x04name\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12-\n\x07version\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x35\n\x15orchestrationInstance\x18\x04 \x01(\x0b\x32\x16.OrchestrationInstance\"\xd9\x02\n\x15\x45xecutionStartedEvent\x12\x0c\n\x04name\x18\x01 \x01(\t\x12-\n\x07version\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x35\n\x15orchestrationInstance\x18\x04 \x01(\x0b\x32\x16.OrchestrationInstance\x12+\n\x0eparentInstance\x18\x05 \x01(\x0b\x32\x13.ParentInstanceInfo\x12;\n\x17scheduledStartTimestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x35\n\x0f\x63orrelationData\x18\x07 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\xa7\x01\n\x17\x45xecutionCompletedEvent\x12\x31\n\x13orchestrationStatus\x18\x01 \x01(\x0e\x32\x14.OrchestrationStatus\x12,\n\x06result\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x0e\x66\x61ilureDetails\x18\x03 \x01(\x0b\x32\x13.TaskFailureDetails\"G\n\x18\x45xecutionTerminatedEvent\x12+\n\x05input\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"~\n\x12TaskScheduledEvent\x12\x0c\n\x04name\x18\x01 \x01(\t\x12-\n\x07version\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"[\n\x12TaskCompletedEvent\x12\x17\n\x0ftaskScheduledId\x18\x01 \x01(\x05\x12,\n\x06result\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"W\n\x0fTaskFailedEvent\x12\x17\n\x0ftaskScheduledId\x18\x01 \x01(\x05\x12+\n\x0e\x66\x61ilureDetails\x18\x02 \x01(\x0b\x32\x13.TaskFailureDetails\"\xa4\x01\n$SubOrchestrationInstanceCreatedEvent\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12-\n\x07version\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"o\n&SubOrchestrationInstanceCompletedEvent\x12\x17\n\x0ftaskScheduledId\x18\x01 \x01(\x05\x12,\n\x06result\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"k\n#SubOrchestrationInstanceFailedEvent\x12\x17\n\x0ftaskScheduledId\x18\x01 \x01(\x05\x12+\n\x0e\x66\x61ilureDetails\x18\x02 \x01(\x0b\x32\x13.TaskFailureDetails\"?\n\x11TimerCreatedEvent\x12*\n\x06\x66ireAt\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"N\n\x0fTimerFiredEvent\x12*\n\x06\x66ireAt\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x0f\n\x07timerId\x18\x02 \x01(\x05\"\x1a\n\x18OrchestratorStartedEvent\"\x1c\n\x1aOrchestratorCompletedEvent\"_\n\x0e\x45ventSentEvent\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"M\n\x10\x45ventRaisedEvent\x12\x0c\n\x04name\x18\x01 \x01(\t\x12+\n\x05input\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x1c\n\x0cGenericEvent\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\t\"D\n\x11HistoryStateEvent\x12/\n\x12orchestrationState\x18\x01 \x01(\x0b\x32\x13.OrchestrationState\"A\n\x12\x43ontinueAsNewEvent\x12+\n\x05input\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"F\n\x17\x45xecutionSuspendedEvent\x12+\n\x05input\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"D\n\x15\x45xecutionResumedEvent\x12+\n\x05input\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x86\t\n\x0cHistoryEvent\x12\x0f\n\x07\x65ventId\x18\x01 \x01(\x05\x12-\n\ttimestamp\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x32\n\x10\x65xecutionStarted\x18\x03 \x01(\x0b\x32\x16.ExecutionStartedEventH\x00\x12\x36\n\x12\x65xecutionCompleted\x18\x04 \x01(\x0b\x32\x18.ExecutionCompletedEventH\x00\x12\x38\n\x13\x65xecutionTerminated\x18\x05 \x01(\x0b\x32\x19.ExecutionTerminatedEventH\x00\x12,\n\rtaskScheduled\x18\x06 \x01(\x0b\x32\x13.TaskScheduledEventH\x00\x12,\n\rtaskCompleted\x18\x07 \x01(\x0b\x32\x13.TaskCompletedEventH\x00\x12&\n\ntaskFailed\x18\x08 \x01(\x0b\x32\x10.TaskFailedEventH\x00\x12P\n\x1fsubOrchestrationInstanceCreated\x18\t \x01(\x0b\x32%.SubOrchestrationInstanceCreatedEventH\x00\x12T\n!subOrchestrationInstanceCompleted\x18\n \x01(\x0b\x32\'.SubOrchestrationInstanceCompletedEventH\x00\x12N\n\x1esubOrchestrationInstanceFailed\x18\x0b \x01(\x0b\x32$.SubOrchestrationInstanceFailedEventH\x00\x12*\n\x0ctimerCreated\x18\x0c \x01(\x0b\x32\x12.TimerCreatedEventH\x00\x12&\n\ntimerFired\x18\r \x01(\x0b\x32\x10.TimerFiredEventH\x00\x12\x38\n\x13orchestratorStarted\x18\x0e \x01(\x0b\x32\x19.OrchestratorStartedEventH\x00\x12<\n\x15orchestratorCompleted\x18\x0f \x01(\x0b\x32\x1b.OrchestratorCompletedEventH\x00\x12$\n\teventSent\x18\x10 \x01(\x0b\x32\x0f.EventSentEventH\x00\x12(\n\x0b\x65ventRaised\x18\x11 \x01(\x0b\x32\x11.EventRaisedEventH\x00\x12%\n\x0cgenericEvent\x18\x12 \x01(\x0b\x32\r.GenericEventH\x00\x12*\n\x0chistoryState\x18\x13 \x01(\x0b\x32\x12.HistoryStateEventH\x00\x12,\n\rcontinueAsNew\x18\x14 \x01(\x0b\x32\x13.ContinueAsNewEventH\x00\x12\x36\n\x12\x65xecutionSuspended\x18\x15 \x01(\x0b\x32\x18.ExecutionSuspendedEventH\x00\x12\x32\n\x10\x65xecutionResumed\x18\x16 \x01(\x0b\x32\x16.ExecutionResumedEventH\x00\x42\x0b\n\teventType\"~\n\x12ScheduleTaskAction\x12\x0c\n\x04name\x18\x01 \x01(\t\x12-\n\x07version\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x9c\x01\n\x1c\x43reateSubOrchestrationAction\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12-\n\x07version\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"?\n\x11\x43reateTimerAction\x12*\n\x06\x66ireAt\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"u\n\x0fSendEventAction\x12(\n\x08instance\x18\x01 \x01(\x0b\x32\x16.OrchestrationInstance\x12\x0c\n\x04name\x18\x02 \x01(\t\x12*\n\x04\x64\x61ta\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\xb4\x02\n\x1b\x43ompleteOrchestrationAction\x12\x31\n\x13orchestrationStatus\x18\x01 \x01(\x0e\x32\x14.OrchestrationStatus\x12,\n\x06result\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12-\n\x07\x64\x65tails\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x30\n\nnewVersion\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12&\n\x0f\x63\x61rryoverEvents\x18\x05 \x03(\x0b\x32\r.HistoryEvent\x12+\n\x0e\x66\x61ilureDetails\x18\x06 \x01(\x0b\x32\x13.TaskFailureDetails\"\xb9\x02\n\x12OrchestratorAction\x12\n\n\x02id\x18\x01 \x01(\x05\x12+\n\x0cscheduleTask\x18\x02 \x01(\x0b\x32\x13.ScheduleTaskActionH\x00\x12?\n\x16\x63reateSubOrchestration\x18\x03 \x01(\x0b\x32\x1d.CreateSubOrchestrationActionH\x00\x12)\n\x0b\x63reateTimer\x18\x04 \x01(\x0b\x32\x12.CreateTimerActionH\x00\x12%\n\tsendEvent\x18\x05 \x01(\x0b\x32\x10.SendEventActionH\x00\x12=\n\x15\x63ompleteOrchestration\x18\x06 \x01(\x0b\x32\x1c.CompleteOrchestrationActionH\x00\x42\x18\n\x16orchestratorActionType\"\xa1\x01\n\x13OrchestratorRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x31\n\x0b\x65xecutionId\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12!\n\npastEvents\x18\x03 \x03(\x0b\x32\r.HistoryEvent\x12 \n\tnewEvents\x18\x04 \x03(\x0b\x32\r.HistoryEvent\"\x84\x01\n\x14OrchestratorResponse\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12$\n\x07\x61\x63tions\x18\x02 \x03(\x0b\x32\x13.OrchestratorAction\x12\x32\n\x0c\x63ustomStatus\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\xd2\x01\n\x15\x43reateInstanceRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12-\n\x07version\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12;\n\x17scheduledStartTimestamp\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\",\n\x16\x43reateInstanceResponse\x12\x12\n\ninstanceId\x18\x01 \x01(\t\"E\n\x12GetInstanceRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x1b\n\x13getInputsAndOutputs\x18\x02 \x01(\x08\"V\n\x13GetInstanceResponse\x12\x0e\n\x06\x65xists\x18\x01 \x01(\x08\x12/\n\x12orchestrationState\x18\x02 \x01(\x0b\x32\x13.OrchestrationState\"Y\n\x15RewindInstanceRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12,\n\x06reason\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x18\n\x16RewindInstanceResponse\"\x81\x04\n\x12OrchestrationState\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12-\n\x07version\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x31\n\x13orchestrationStatus\x18\x04 \x01(\x0e\x32\x14.OrchestrationStatus\x12;\n\x17scheduledStartTimestamp\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x34\n\x10\x63reatedTimestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x38\n\x14lastUpdatedTimestamp\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12+\n\x05input\x18\x08 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12,\n\x06output\x18\t \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x32\n\x0c\x63ustomStatus\x18\n \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x0e\x66\x61ilureDetails\x18\x0b \x01(\x0b\x32\x13.TaskFailureDetails\"b\n\x11RaiseEventRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x14\n\x12RaiseEventResponse\"T\n\x10TerminateRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12,\n\x06output\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x13\n\x11TerminateResponse\"R\n\x0eSuspendRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12,\n\x06reason\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x11\n\x0fSuspendResponse\"Q\n\rResumeRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12,\n\x06reason\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x10\n\x0eResumeResponse\"6\n\x15QueryInstancesRequest\x12\x1d\n\x05query\x18\x01 \x01(\x0b\x32\x0e.InstanceQuery\"\x82\x03\n\rInstanceQuery\x12+\n\rruntimeStatus\x18\x01 \x03(\x0e\x32\x14.OrchestrationStatus\x12\x33\n\x0f\x63reatedTimeFrom\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x31\n\rcreatedTimeTo\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x32\n\x0ctaskHubNames\x18\x04 \x03(\x0b\x32\x1c.google.protobuf.StringValue\x12\x18\n\x10maxInstanceCount\x18\x05 \x01(\x05\x12\x37\n\x11\x63ontinuationToken\x18\x06 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x36\n\x10instanceIdPrefix\x18\x07 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x1d\n\x15\x66\x65tchInputsAndOutputs\x18\x08 \x01(\x08\"\x82\x01\n\x16QueryInstancesResponse\x12/\n\x12orchestrationState\x18\x01 \x03(\x0b\x32\x13.OrchestrationState\x12\x37\n\x11\x63ontinuationToken\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"m\n\x15PurgeInstancesRequest\x12\x14\n\ninstanceId\x18\x01 \x01(\tH\x00\x12\x33\n\x13purgeInstanceFilter\x18\x02 \x01(\x0b\x32\x14.PurgeInstanceFilterH\x00\x42\t\n\x07request\"\xaa\x01\n\x13PurgeInstanceFilter\x12\x33\n\x0f\x63reatedTimeFrom\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x31\n\rcreatedTimeTo\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12+\n\rruntimeStatus\x18\x03 \x03(\x0e\x32\x14.OrchestrationStatus\"6\n\x16PurgeInstancesResponse\x12\x1c\n\x14\x64\x65letedInstanceCount\x18\x01 \x01(\x05\"0\n\x14\x43reateTaskHubRequest\x12\x18\n\x10recreateIfExists\x18\x01 \x01(\x08\"\x17\n\x15\x43reateTaskHubResponse\"\x16\n\x14\x44\x65leteTaskHubRequest\"\x17\n\x15\x44\x65leteTaskHubResponse\"\x15\n\x13GetWorkItemsRequest\"w\n\x08WorkItem\x12\x33\n\x13orchestratorRequest\x18\x01 \x01(\x0b\x32\x14.OrchestratorRequestH\x00\x12+\n\x0f\x61\x63tivityRequest\x18\x02 \x01(\x0b\x32\x10.ActivityRequestH\x00\x42\t\n\x07request\"\x16\n\x14\x43ompleteTaskResponse*\xb5\x02\n\x13OrchestrationStatus\x12 \n\x1cORCHESTRATION_STATUS_RUNNING\x10\x00\x12\"\n\x1eORCHESTRATION_STATUS_COMPLETED\x10\x01\x12)\n%ORCHESTRATION_STATUS_CONTINUED_AS_NEW\x10\x02\x12\x1f\n\x1bORCHESTRATION_STATUS_FAILED\x10\x03\x12!\n\x1dORCHESTRATION_STATUS_CANCELED\x10\x04\x12#\n\x1fORCHESTRATION_STATUS_TERMINATED\x10\x05\x12 \n\x1cORCHESTRATION_STATUS_PENDING\x10\x06\x12\"\n\x1eORCHESTRATION_STATUS_SUSPENDED\x10\x07\x32\xbb\x08\n\x15TaskHubSidecarService\x12\x37\n\x05Hello\x12\x16.google.protobuf.Empty\x1a\x16.google.protobuf.Empty\x12@\n\rStartInstance\x12\x16.CreateInstanceRequest\x1a\x17.CreateInstanceResponse\x12\x38\n\x0bGetInstance\x12\x13.GetInstanceRequest\x1a\x14.GetInstanceResponse\x12\x41\n\x0eRewindInstance\x12\x16.RewindInstanceRequest\x1a\x17.RewindInstanceResponse\x12\x41\n\x14WaitForInstanceStart\x12\x13.GetInstanceRequest\x1a\x14.GetInstanceResponse\x12\x46\n\x19WaitForInstanceCompletion\x12\x13.GetInstanceRequest\x1a\x14.GetInstanceResponse\x12\x35\n\nRaiseEvent\x12\x12.RaiseEventRequest\x1a\x13.RaiseEventResponse\x12:\n\x11TerminateInstance\x12\x11.TerminateRequest\x1a\x12.TerminateResponse\x12\x34\n\x0fSuspendInstance\x12\x0f.SuspendRequest\x1a\x10.SuspendResponse\x12\x31\n\x0eResumeInstance\x12\x0e.ResumeRequest\x1a\x0f.ResumeResponse\x12\x41\n\x0eQueryInstances\x12\x16.QueryInstancesRequest\x1a\x17.QueryInstancesResponse\x12\x41\n\x0ePurgeInstances\x12\x16.PurgeInstancesRequest\x1a\x17.PurgeInstancesResponse\x12\x31\n\x0cGetWorkItems\x12\x14.GetWorkItemsRequest\x1a\t.WorkItem0\x01\x12@\n\x14\x43ompleteActivityTask\x12\x11.ActivityResponse\x1a\x15.CompleteTaskResponse\x12H\n\x18\x43ompleteOrchestratorTask\x12\x15.OrchestratorResponse\x1a\x15.CompleteTaskResponse\x12>\n\rCreateTaskHub\x12\x15.CreateTaskHubRequest\x1a\x16.CreateTaskHubResponse\x12>\n\rDeleteTaskHub\x12\x15.DeleteTaskHubRequest\x1a\x16.DeleteTaskHubResponseBf\n1com.microsoft.durabletask.implementation.protobufZ\x10/internal/protos\xaa\x02\x1eMicrosoft.DurableTask.Protobufb\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1aorchestrator_service.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1egoogle/protobuf/wrappers.proto\x1a\x1bgoogle/protobuf/empty.proto\"^\n\x15OrchestrationInstance\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x31\n\x0b\x65xecutionId\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\xc2\x01\n\x0f\x41\x63tivityRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12-\n\x07version\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x35\n\x15orchestrationInstance\x18\x04 \x01(\x0b\x32\x16.OrchestrationInstance\x12\x0e\n\x06taskId\x18\x05 \x01(\x05\"\x91\x01\n\x10\x41\x63tivityResponse\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0e\n\x06taskId\x18\x02 \x01(\x05\x12,\n\x06result\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x0e\x66\x61ilureDetails\x18\x04 \x01(\x0b\x32\x13.TaskFailureDetails\"\xb2\x01\n\x12TaskFailureDetails\x12\x11\n\terrorType\x18\x01 \x01(\t\x12\x14\n\x0c\x65rrorMessage\x18\x02 \x01(\t\x12\x30\n\nstackTrace\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12)\n\x0cinnerFailure\x18\x04 \x01(\x0b\x32\x13.TaskFailureDetails\x12\x16\n\x0eisNonRetriable\x18\x05 \x01(\x08\"\xbf\x01\n\x12ParentInstanceInfo\x12\x17\n\x0ftaskScheduledId\x18\x01 \x01(\x05\x12*\n\x04name\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12-\n\x07version\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x35\n\x15orchestrationInstance\x18\x04 \x01(\x0b\x32\x16.OrchestrationInstance\"i\n\x0cTraceContext\x12\x13\n\x0btraceParent\x18\x01 \x01(\t\x12\x12\n\x06spanID\x18\x02 \x01(\tB\x02\x18\x01\x12\x30\n\ntraceState\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x88\x03\n\x15\x45xecutionStartedEvent\x12\x0c\n\x04name\x18\x01 \x01(\t\x12-\n\x07version\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x35\n\x15orchestrationInstance\x18\x04 \x01(\x0b\x32\x16.OrchestrationInstance\x12+\n\x0eparentInstance\x18\x05 \x01(\x0b\x32\x13.ParentInstanceInfo\x12;\n\x17scheduledStartTimestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12)\n\x12parentTraceContext\x18\x07 \x01(\x0b\x32\r.TraceContext\x12\x39\n\x13orchestrationSpanID\x18\x08 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\xa7\x01\n\x17\x45xecutionCompletedEvent\x12\x31\n\x13orchestrationStatus\x18\x01 \x01(\x0e\x32\x14.OrchestrationStatus\x12,\n\x06result\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x0e\x66\x61ilureDetails\x18\x03 \x01(\x0b\x32\x13.TaskFailureDetails\"X\n\x18\x45xecutionTerminatedEvent\x12+\n\x05input\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x0f\n\x07recurse\x18\x02 \x01(\x08\"\xa9\x01\n\x12TaskScheduledEvent\x12\x0c\n\x04name\x18\x01 \x01(\t\x12-\n\x07version\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12)\n\x12parentTraceContext\x18\x04 \x01(\x0b\x32\r.TraceContext\"[\n\x12TaskCompletedEvent\x12\x17\n\x0ftaskScheduledId\x18\x01 \x01(\x05\x12,\n\x06result\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"W\n\x0fTaskFailedEvent\x12\x17\n\x0ftaskScheduledId\x18\x01 \x01(\x05\x12+\n\x0e\x66\x61ilureDetails\x18\x02 \x01(\x0b\x32\x13.TaskFailureDetails\"\xcf\x01\n$SubOrchestrationInstanceCreatedEvent\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12-\n\x07version\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12)\n\x12parentTraceContext\x18\x05 \x01(\x0b\x32\r.TraceContext\"o\n&SubOrchestrationInstanceCompletedEvent\x12\x17\n\x0ftaskScheduledId\x18\x01 \x01(\x05\x12,\n\x06result\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"k\n#SubOrchestrationInstanceFailedEvent\x12\x17\n\x0ftaskScheduledId\x18\x01 \x01(\x05\x12+\n\x0e\x66\x61ilureDetails\x18\x02 \x01(\x0b\x32\x13.TaskFailureDetails\"?\n\x11TimerCreatedEvent\x12*\n\x06\x66ireAt\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"N\n\x0fTimerFiredEvent\x12*\n\x06\x66ireAt\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x0f\n\x07timerId\x18\x02 \x01(\x05\"\x1a\n\x18OrchestratorStartedEvent\"\x1c\n\x1aOrchestratorCompletedEvent\"_\n\x0e\x45ventSentEvent\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"M\n\x10\x45ventRaisedEvent\x12\x0c\n\x04name\x18\x01 \x01(\t\x12+\n\x05input\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x1c\n\x0cGenericEvent\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\t\"D\n\x11HistoryStateEvent\x12/\n\x12orchestrationState\x18\x01 \x01(\x0b\x32\x13.OrchestrationState\"A\n\x12\x43ontinueAsNewEvent\x12+\n\x05input\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"F\n\x17\x45xecutionSuspendedEvent\x12+\n\x05input\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"D\n\x15\x45xecutionResumedEvent\x12+\n\x05input\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x86\t\n\x0cHistoryEvent\x12\x0f\n\x07\x65ventId\x18\x01 \x01(\x05\x12-\n\ttimestamp\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x32\n\x10\x65xecutionStarted\x18\x03 \x01(\x0b\x32\x16.ExecutionStartedEventH\x00\x12\x36\n\x12\x65xecutionCompleted\x18\x04 \x01(\x0b\x32\x18.ExecutionCompletedEventH\x00\x12\x38\n\x13\x65xecutionTerminated\x18\x05 \x01(\x0b\x32\x19.ExecutionTerminatedEventH\x00\x12,\n\rtaskScheduled\x18\x06 \x01(\x0b\x32\x13.TaskScheduledEventH\x00\x12,\n\rtaskCompleted\x18\x07 \x01(\x0b\x32\x13.TaskCompletedEventH\x00\x12&\n\ntaskFailed\x18\x08 \x01(\x0b\x32\x10.TaskFailedEventH\x00\x12P\n\x1fsubOrchestrationInstanceCreated\x18\t \x01(\x0b\x32%.SubOrchestrationInstanceCreatedEventH\x00\x12T\n!subOrchestrationInstanceCompleted\x18\n \x01(\x0b\x32\'.SubOrchestrationInstanceCompletedEventH\x00\x12N\n\x1esubOrchestrationInstanceFailed\x18\x0b \x01(\x0b\x32$.SubOrchestrationInstanceFailedEventH\x00\x12*\n\x0ctimerCreated\x18\x0c \x01(\x0b\x32\x12.TimerCreatedEventH\x00\x12&\n\ntimerFired\x18\r \x01(\x0b\x32\x10.TimerFiredEventH\x00\x12\x38\n\x13orchestratorStarted\x18\x0e \x01(\x0b\x32\x19.OrchestratorStartedEventH\x00\x12<\n\x15orchestratorCompleted\x18\x0f \x01(\x0b\x32\x1b.OrchestratorCompletedEventH\x00\x12$\n\teventSent\x18\x10 \x01(\x0b\x32\x0f.EventSentEventH\x00\x12(\n\x0b\x65ventRaised\x18\x11 \x01(\x0b\x32\x11.EventRaisedEventH\x00\x12%\n\x0cgenericEvent\x18\x12 \x01(\x0b\x32\r.GenericEventH\x00\x12*\n\x0chistoryState\x18\x13 \x01(\x0b\x32\x12.HistoryStateEventH\x00\x12,\n\rcontinueAsNew\x18\x14 \x01(\x0b\x32\x13.ContinueAsNewEventH\x00\x12\x36\n\x12\x65xecutionSuspended\x18\x15 \x01(\x0b\x32\x18.ExecutionSuspendedEventH\x00\x12\x32\n\x10\x65xecutionResumed\x18\x16 \x01(\x0b\x32\x16.ExecutionResumedEventH\x00\x42\x0b\n\teventType\"~\n\x12ScheduleTaskAction\x12\x0c\n\x04name\x18\x01 \x01(\t\x12-\n\x07version\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x9c\x01\n\x1c\x43reateSubOrchestrationAction\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12-\n\x07version\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"?\n\x11\x43reateTimerAction\x12*\n\x06\x66ireAt\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"u\n\x0fSendEventAction\x12(\n\x08instance\x18\x01 \x01(\x0b\x32\x16.OrchestrationInstance\x12\x0c\n\x04name\x18\x02 \x01(\t\x12*\n\x04\x64\x61ta\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\xb4\x02\n\x1b\x43ompleteOrchestrationAction\x12\x31\n\x13orchestrationStatus\x18\x01 \x01(\x0e\x32\x14.OrchestrationStatus\x12,\n\x06result\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12-\n\x07\x64\x65tails\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x30\n\nnewVersion\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12&\n\x0f\x63\x61rryoverEvents\x18\x05 \x03(\x0b\x32\r.HistoryEvent\x12+\n\x0e\x66\x61ilureDetails\x18\x06 \x01(\x0b\x32\x13.TaskFailureDetails\"q\n\x1cTerminateOrchestrationAction\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12,\n\x06reason\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x0f\n\x07recurse\x18\x03 \x01(\x08\"\xfa\x02\n\x12OrchestratorAction\x12\n\n\x02id\x18\x01 \x01(\x05\x12+\n\x0cscheduleTask\x18\x02 \x01(\x0b\x32\x13.ScheduleTaskActionH\x00\x12?\n\x16\x63reateSubOrchestration\x18\x03 \x01(\x0b\x32\x1d.CreateSubOrchestrationActionH\x00\x12)\n\x0b\x63reateTimer\x18\x04 \x01(\x0b\x32\x12.CreateTimerActionH\x00\x12%\n\tsendEvent\x18\x05 \x01(\x0b\x32\x10.SendEventActionH\x00\x12=\n\x15\x63ompleteOrchestration\x18\x06 \x01(\x0b\x32\x1c.CompleteOrchestrationActionH\x00\x12?\n\x16terminateOrchestration\x18\x07 \x01(\x0b\x32\x1d.TerminateOrchestrationActionH\x00\x42\x18\n\x16orchestratorActionType\"\xda\x01\n\x13OrchestratorRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x31\n\x0b\x65xecutionId\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12!\n\npastEvents\x18\x03 \x03(\x0b\x32\r.HistoryEvent\x12 \n\tnewEvents\x18\x04 \x03(\x0b\x32\r.HistoryEvent\x12\x37\n\x10\x65ntityParameters\x18\x05 \x01(\x0b\x32\x1d.OrchestratorEntityParameters\"\x84\x01\n\x14OrchestratorResponse\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12$\n\x07\x61\x63tions\x18\x02 \x03(\x0b\x32\x13.OrchestratorAction\x12\x32\n\x0c\x63ustomStatus\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\xd2\x01\n\x15\x43reateInstanceRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12-\n\x07version\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12;\n\x17scheduledStartTimestamp\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\",\n\x16\x43reateInstanceResponse\x12\x12\n\ninstanceId\x18\x01 \x01(\t\"E\n\x12GetInstanceRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x1b\n\x13getInputsAndOutputs\x18\x02 \x01(\x08\"V\n\x13GetInstanceResponse\x12\x0e\n\x06\x65xists\x18\x01 \x01(\x08\x12/\n\x12orchestrationState\x18\x02 \x01(\x0b\x32\x13.OrchestrationState\"Y\n\x15RewindInstanceRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12,\n\x06reason\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x18\n\x16RewindInstanceResponse\"\x81\x04\n\x12OrchestrationState\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12-\n\x07version\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x31\n\x13orchestrationStatus\x18\x04 \x01(\x0e\x32\x14.OrchestrationStatus\x12;\n\x17scheduledStartTimestamp\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x34\n\x10\x63reatedTimestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x38\n\x14lastUpdatedTimestamp\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12+\n\x05input\x18\x08 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12,\n\x06output\x18\t \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x32\n\x0c\x63ustomStatus\x18\n \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x0e\x66\x61ilureDetails\x18\x0b \x01(\x0b\x32\x13.TaskFailureDetails\"b\n\x11RaiseEventRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x14\n\x12RaiseEventResponse\"g\n\x10TerminateRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12,\n\x06output\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x11\n\trecursive\x18\x03 \x01(\x08\"\x13\n\x11TerminateResponse\"R\n\x0eSuspendRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12,\n\x06reason\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x11\n\x0fSuspendResponse\"Q\n\rResumeRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12,\n\x06reason\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x10\n\x0eResumeResponse\"6\n\x15QueryInstancesRequest\x12\x1d\n\x05query\x18\x01 \x01(\x0b\x32\x0e.InstanceQuery\"\x82\x03\n\rInstanceQuery\x12+\n\rruntimeStatus\x18\x01 \x03(\x0e\x32\x14.OrchestrationStatus\x12\x33\n\x0f\x63reatedTimeFrom\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x31\n\rcreatedTimeTo\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x32\n\x0ctaskHubNames\x18\x04 \x03(\x0b\x32\x1c.google.protobuf.StringValue\x12\x18\n\x10maxInstanceCount\x18\x05 \x01(\x05\x12\x37\n\x11\x63ontinuationToken\x18\x06 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x36\n\x10instanceIdPrefix\x18\x07 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x1d\n\x15\x66\x65tchInputsAndOutputs\x18\x08 \x01(\x08\"\x82\x01\n\x16QueryInstancesResponse\x12/\n\x12orchestrationState\x18\x01 \x03(\x0b\x32\x13.OrchestrationState\x12\x37\n\x11\x63ontinuationToken\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"m\n\x15PurgeInstancesRequest\x12\x14\n\ninstanceId\x18\x01 \x01(\tH\x00\x12\x33\n\x13purgeInstanceFilter\x18\x02 \x01(\x0b\x32\x14.PurgeInstanceFilterH\x00\x42\t\n\x07request\"\xaa\x01\n\x13PurgeInstanceFilter\x12\x33\n\x0f\x63reatedTimeFrom\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x31\n\rcreatedTimeTo\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12+\n\rruntimeStatus\x18\x03 \x03(\x0e\x32\x14.OrchestrationStatus\"6\n\x16PurgeInstancesResponse\x12\x1c\n\x14\x64\x65letedInstanceCount\x18\x01 \x01(\x05\"0\n\x14\x43reateTaskHubRequest\x12\x18\n\x10recreateIfExists\x18\x01 \x01(\x08\"\x17\n\x15\x43reateTaskHubResponse\"\x16\n\x14\x44\x65leteTaskHubRequest\"\x17\n\x15\x44\x65leteTaskHubResponse\"\xaa\x01\n\x13SignalEntityRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x11\n\trequestId\x18\x04 \x01(\t\x12\x31\n\rscheduledTime\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\x16\n\x14SignalEntityResponse\"<\n\x10GetEntityRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x14\n\x0cincludeState\x18\x02 \x01(\x08\"D\n\x11GetEntityResponse\x12\x0e\n\x06\x65xists\x18\x01 \x01(\x08\x12\x1f\n\x06\x65ntity\x18\x02 \x01(\x0b\x32\x0f.EntityMetadata\"\xcb\x02\n\x0b\x45ntityQuery\x12:\n\x14instanceIdStartsWith\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x34\n\x10lastModifiedFrom\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x32\n\x0elastModifiedTo\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x14\n\x0cincludeState\x18\x04 \x01(\x08\x12\x18\n\x10includeTransient\x18\x05 \x01(\x08\x12-\n\x08pageSize\x18\x06 \x01(\x0b\x32\x1b.google.protobuf.Int32Value\x12\x37\n\x11\x63ontinuationToken\x18\x07 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"3\n\x14QueryEntitiesRequest\x12\x1b\n\x05query\x18\x01 \x01(\x0b\x32\x0c.EntityQuery\"s\n\x15QueryEntitiesResponse\x12!\n\x08\x65ntities\x18\x01 \x03(\x0b\x32\x0f.EntityMetadata\x12\x37\n\x11\x63ontinuationToken\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\xdb\x01\n\x0e\x45ntityMetadata\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x34\n\x10lastModifiedTime\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x18\n\x10\x62\x61\x63klogQueueSize\x18\x03 \x01(\x05\x12.\n\x08lockedBy\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x35\n\x0fserializedState\x18\x05 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"\x8f\x01\n\x19\x43leanEntityStorageRequest\x12\x37\n\x11\x63ontinuationToken\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x1b\n\x13removeEmptyEntities\x18\x02 \x01(\x08\x12\x1c\n\x14releaseOrphanedLocks\x18\x03 \x01(\x08\"\x92\x01\n\x1a\x43leanEntityStorageResponse\x12\x37\n\x11\x63ontinuationToken\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x1c\n\x14\x65mptyEntitiesRemoved\x18\x02 \x01(\x05\x12\x1d\n\x15orphanedLocksReleased\x18\x03 \x01(\x05\"]\n\x1cOrchestratorEntityParameters\x12=\n\x1a\x65ntityMessageReorderWindow\x18\x01 \x01(\x0b\x32\x19.google.protobuf.Duration\"\x82\x01\n\x12\x45ntityBatchRequest\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x31\n\x0b\x65ntityState\x18\x02 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12%\n\noperations\x18\x03 \x03(\x0b\x32\x11.OperationRequest\"\xb9\x01\n\x11\x45ntityBatchResult\x12!\n\x07results\x18\x01 \x03(\x0b\x32\x10.OperationResult\x12!\n\x07\x61\x63tions\x18\x02 \x03(\x0b\x32\x10.OperationAction\x12\x31\n\x0b\x65ntityState\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x0e\x66\x61ilureDetails\x18\x04 \x01(\x0b\x32\x13.TaskFailureDetails\"e\n\x10OperationRequest\x12\x11\n\toperation\x18\x01 \x01(\t\x12\x11\n\trequestId\x18\x02 \x01(\t\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"w\n\x0fOperationResult\x12*\n\x07success\x18\x01 \x01(\x0b\x32\x17.OperationResultSuccessH\x00\x12*\n\x07\x66\x61ilure\x18\x02 \x01(\x0b\x32\x17.OperationResultFailureH\x00\x42\x0c\n\nresultType\"F\n\x16OperationResultSuccess\x12,\n\x06result\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"E\n\x16OperationResultFailure\x12+\n\x0e\x66\x61ilureDetails\x18\x01 \x01(\x0b\x32\x13.TaskFailureDetails\"\x9c\x01\n\x0fOperationAction\x12\n\n\x02id\x18\x01 \x01(\x05\x12\'\n\nsendSignal\x18\x02 \x01(\x0b\x32\x11.SendSignalActionH\x00\x12=\n\x15startNewOrchestration\x18\x03 \x01(\x0b\x32\x1c.StartNewOrchestrationActionH\x00\x42\x15\n\x13operationActionType\"\x94\x01\n\x10SendSignalAction\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12+\n\x05input\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x31\n\rscheduledTime\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\xce\x01\n\x1bStartNewOrchestrationAction\x12\x12\n\ninstanceId\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12-\n\x07version\x18\x03 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12+\n\x05input\x18\x04 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x31\n\rscheduledTime\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\x15\n\x13GetWorkItemsRequest\"\xa5\x01\n\x08WorkItem\x12\x33\n\x13orchestratorRequest\x18\x01 \x01(\x0b\x32\x14.OrchestratorRequestH\x00\x12+\n\x0f\x61\x63tivityRequest\x18\x02 \x01(\x0b\x32\x10.ActivityRequestH\x00\x12,\n\rentityRequest\x18\x03 \x01(\x0b\x32\x13.EntityBatchRequestH\x00\x42\t\n\x07request\"\x16\n\x14\x43ompleteTaskResponse*\xb5\x02\n\x13OrchestrationStatus\x12 \n\x1cORCHESTRATION_STATUS_RUNNING\x10\x00\x12\"\n\x1eORCHESTRATION_STATUS_COMPLETED\x10\x01\x12)\n%ORCHESTRATION_STATUS_CONTINUED_AS_NEW\x10\x02\x12\x1f\n\x1bORCHESTRATION_STATUS_FAILED\x10\x03\x12!\n\x1dORCHESTRATION_STATUS_CANCELED\x10\x04\x12#\n\x1fORCHESTRATION_STATUS_TERMINATED\x10\x05\x12 \n\x1cORCHESTRATION_STATUS_PENDING\x10\x06\x12\"\n\x1eORCHESTRATION_STATUS_SUSPENDED\x10\x07\x32\xfc\n\n\x15TaskHubSidecarService\x12\x37\n\x05Hello\x12\x16.google.protobuf.Empty\x1a\x16.google.protobuf.Empty\x12@\n\rStartInstance\x12\x16.CreateInstanceRequest\x1a\x17.CreateInstanceResponse\x12\x38\n\x0bGetInstance\x12\x13.GetInstanceRequest\x1a\x14.GetInstanceResponse\x12\x41\n\x0eRewindInstance\x12\x16.RewindInstanceRequest\x1a\x17.RewindInstanceResponse\x12\x41\n\x14WaitForInstanceStart\x12\x13.GetInstanceRequest\x1a\x14.GetInstanceResponse\x12\x46\n\x19WaitForInstanceCompletion\x12\x13.GetInstanceRequest\x1a\x14.GetInstanceResponse\x12\x35\n\nRaiseEvent\x12\x12.RaiseEventRequest\x1a\x13.RaiseEventResponse\x12:\n\x11TerminateInstance\x12\x11.TerminateRequest\x1a\x12.TerminateResponse\x12\x34\n\x0fSuspendInstance\x12\x0f.SuspendRequest\x1a\x10.SuspendResponse\x12\x31\n\x0eResumeInstance\x12\x0e.ResumeRequest\x1a\x0f.ResumeResponse\x12\x41\n\x0eQueryInstances\x12\x16.QueryInstancesRequest\x1a\x17.QueryInstancesResponse\x12\x41\n\x0ePurgeInstances\x12\x16.PurgeInstancesRequest\x1a\x17.PurgeInstancesResponse\x12\x31\n\x0cGetWorkItems\x12\x14.GetWorkItemsRequest\x1a\t.WorkItem0\x01\x12@\n\x14\x43ompleteActivityTask\x12\x11.ActivityResponse\x1a\x15.CompleteTaskResponse\x12H\n\x18\x43ompleteOrchestratorTask\x12\x15.OrchestratorResponse\x1a\x15.CompleteTaskResponse\x12?\n\x12\x43ompleteEntityTask\x12\x12.EntityBatchResult\x1a\x15.CompleteTaskResponse\x12>\n\rCreateTaskHub\x12\x15.CreateTaskHubRequest\x1a\x16.CreateTaskHubResponse\x12>\n\rDeleteTaskHub\x12\x15.DeleteTaskHubRequest\x1a\x16.DeleteTaskHubResponse\x12;\n\x0cSignalEntity\x12\x14.SignalEntityRequest\x1a\x15.SignalEntityResponse\x12\x32\n\tGetEntity\x12\x11.GetEntityRequest\x1a\x12.GetEntityResponse\x12>\n\rQueryEntities\x12\x15.QueryEntitiesRequest\x1a\x16.QueryEntitiesResponse\x12M\n\x12\x43leanEntityStorage\x12\x1a.CleanEntityStorageRequest\x1a\x1b.CleanEntityStorageResponseBf\n1com.microsoft.durabletask.implementation.protobufZ\x10/internal/protos\xaa\x02\x1eMicrosoft.DurableTask.Protobufb\x06proto3') _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals()) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'orchestrator_service_pb2', globals()) @@ -24,132 +25,178 @@ DESCRIPTOR._options = None DESCRIPTOR._serialized_options = b'\n1com.microsoft.durabletask.implementation.protobufZ\020/internal/protos\252\002\036Microsoft.DurableTask.Protobuf' - _ORCHESTRATIONSTATUS._serialized_start=8171 - _ORCHESTRATIONSTATUS._serialized_end=8480 - _ORCHESTRATIONINSTANCE._serialized_start=124 - _ORCHESTRATIONINSTANCE._serialized_end=218 - _ACTIVITYREQUEST._serialized_start=221 - _ACTIVITYREQUEST._serialized_end=415 - _ACTIVITYRESPONSE._serialized_start=418 - _ACTIVITYRESPONSE._serialized_end=563 - _TASKFAILUREDETAILS._serialized_start=566 - _TASKFAILUREDETAILS._serialized_end=744 - _PARENTINSTANCEINFO._serialized_start=747 - _PARENTINSTANCEINFO._serialized_end=938 - _EXECUTIONSTARTEDEVENT._serialized_start=941 - _EXECUTIONSTARTEDEVENT._serialized_end=1286 - _EXECUTIONCOMPLETEDEVENT._serialized_start=1289 - _EXECUTIONCOMPLETEDEVENT._serialized_end=1456 - _EXECUTIONTERMINATEDEVENT._serialized_start=1458 - _EXECUTIONTERMINATEDEVENT._serialized_end=1529 - _TASKSCHEDULEDEVENT._serialized_start=1531 - _TASKSCHEDULEDEVENT._serialized_end=1657 - _TASKCOMPLETEDEVENT._serialized_start=1659 - _TASKCOMPLETEDEVENT._serialized_end=1750 - _TASKFAILEDEVENT._serialized_start=1752 - _TASKFAILEDEVENT._serialized_end=1839 - _SUBORCHESTRATIONINSTANCECREATEDEVENT._serialized_start=1842 - _SUBORCHESTRATIONINSTANCECREATEDEVENT._serialized_end=2006 - _SUBORCHESTRATIONINSTANCECOMPLETEDEVENT._serialized_start=2008 - _SUBORCHESTRATIONINSTANCECOMPLETEDEVENT._serialized_end=2119 - _SUBORCHESTRATIONINSTANCEFAILEDEVENT._serialized_start=2121 - _SUBORCHESTRATIONINSTANCEFAILEDEVENT._serialized_end=2228 - _TIMERCREATEDEVENT._serialized_start=2230 - _TIMERCREATEDEVENT._serialized_end=2293 - _TIMERFIREDEVENT._serialized_start=2295 - _TIMERFIREDEVENT._serialized_end=2373 - _ORCHESTRATORSTARTEDEVENT._serialized_start=2375 - _ORCHESTRATORSTARTEDEVENT._serialized_end=2401 - _ORCHESTRATORCOMPLETEDEVENT._serialized_start=2403 - _ORCHESTRATORCOMPLETEDEVENT._serialized_end=2431 - _EVENTSENTEVENT._serialized_start=2433 - _EVENTSENTEVENT._serialized_end=2528 - _EVENTRAISEDEVENT._serialized_start=2530 - _EVENTRAISEDEVENT._serialized_end=2607 - _GENERICEVENT._serialized_start=2609 - _GENERICEVENT._serialized_end=2637 - _HISTORYSTATEEVENT._serialized_start=2639 - _HISTORYSTATEEVENT._serialized_end=2707 - _CONTINUEASNEWEVENT._serialized_start=2709 - _CONTINUEASNEWEVENT._serialized_end=2774 - _EXECUTIONSUSPENDEDEVENT._serialized_start=2776 - _EXECUTIONSUSPENDEDEVENT._serialized_end=2846 - _EXECUTIONRESUMEDEVENT._serialized_start=2848 - _EXECUTIONRESUMEDEVENT._serialized_end=2916 - _HISTORYEVENT._serialized_start=2919 - _HISTORYEVENT._serialized_end=4077 - _SCHEDULETASKACTION._serialized_start=4079 - _SCHEDULETASKACTION._serialized_end=4205 - _CREATESUBORCHESTRATIONACTION._serialized_start=4208 - _CREATESUBORCHESTRATIONACTION._serialized_end=4364 - _CREATETIMERACTION._serialized_start=4366 - _CREATETIMERACTION._serialized_end=4429 - _SENDEVENTACTION._serialized_start=4431 - _SENDEVENTACTION._serialized_end=4548 - _COMPLETEORCHESTRATIONACTION._serialized_start=4551 - _COMPLETEORCHESTRATIONACTION._serialized_end=4859 - _ORCHESTRATORACTION._serialized_start=4862 - _ORCHESTRATORACTION._serialized_end=5175 - _ORCHESTRATORREQUEST._serialized_start=5178 - _ORCHESTRATORREQUEST._serialized_end=5339 - _ORCHESTRATORRESPONSE._serialized_start=5342 - _ORCHESTRATORRESPONSE._serialized_end=5474 - _CREATEINSTANCEREQUEST._serialized_start=5477 - _CREATEINSTANCEREQUEST._serialized_end=5687 - _CREATEINSTANCERESPONSE._serialized_start=5689 - _CREATEINSTANCERESPONSE._serialized_end=5733 - _GETINSTANCEREQUEST._serialized_start=5735 - _GETINSTANCEREQUEST._serialized_end=5804 - _GETINSTANCERESPONSE._serialized_start=5806 - _GETINSTANCERESPONSE._serialized_end=5892 - _REWINDINSTANCEREQUEST._serialized_start=5894 - _REWINDINSTANCEREQUEST._serialized_end=5983 - _REWINDINSTANCERESPONSE._serialized_start=5985 - _REWINDINSTANCERESPONSE._serialized_end=6009 - _ORCHESTRATIONSTATE._serialized_start=6012 - _ORCHESTRATIONSTATE._serialized_end=6525 - _RAISEEVENTREQUEST._serialized_start=6527 - _RAISEEVENTREQUEST._serialized_end=6625 - _RAISEEVENTRESPONSE._serialized_start=6627 - _RAISEEVENTRESPONSE._serialized_end=6647 - _TERMINATEREQUEST._serialized_start=6649 - _TERMINATEREQUEST._serialized_end=6733 - _TERMINATERESPONSE._serialized_start=6735 - _TERMINATERESPONSE._serialized_end=6754 - _SUSPENDREQUEST._serialized_start=6756 - _SUSPENDREQUEST._serialized_end=6838 - _SUSPENDRESPONSE._serialized_start=6840 - _SUSPENDRESPONSE._serialized_end=6857 - _RESUMEREQUEST._serialized_start=6859 - _RESUMEREQUEST._serialized_end=6940 - _RESUMERESPONSE._serialized_start=6942 - _RESUMERESPONSE._serialized_end=6958 - _QUERYINSTANCESREQUEST._serialized_start=6960 - _QUERYINSTANCESREQUEST._serialized_end=7014 - _INSTANCEQUERY._serialized_start=7017 - _INSTANCEQUERY._serialized_end=7403 - _QUERYINSTANCESRESPONSE._serialized_start=7406 - _QUERYINSTANCESRESPONSE._serialized_end=7536 - _PURGEINSTANCESREQUEST._serialized_start=7538 - _PURGEINSTANCESREQUEST._serialized_end=7647 - _PURGEINSTANCEFILTER._serialized_start=7650 - _PURGEINSTANCEFILTER._serialized_end=7820 - _PURGEINSTANCESRESPONSE._serialized_start=7822 - _PURGEINSTANCESRESPONSE._serialized_end=7876 - _CREATETASKHUBREQUEST._serialized_start=7878 - _CREATETASKHUBREQUEST._serialized_end=7926 - _CREATETASKHUBRESPONSE._serialized_start=7928 - _CREATETASKHUBRESPONSE._serialized_end=7951 - _DELETETASKHUBREQUEST._serialized_start=7953 - _DELETETASKHUBREQUEST._serialized_end=7975 - _DELETETASKHUBRESPONSE._serialized_start=7977 - _DELETETASKHUBRESPONSE._serialized_end=8000 - _GETWORKITEMSREQUEST._serialized_start=8002 - _GETWORKITEMSREQUEST._serialized_end=8023 - _WORKITEM._serialized_start=8025 - _WORKITEM._serialized_end=8144 - _COMPLETETASKRESPONSE._serialized_start=8146 - _COMPLETETASKRESPONSE._serialized_end=8168 - _TASKHUBSIDECARSERVICE._serialized_start=8483 - _TASKHUBSIDECARSERVICE._serialized_end=9566 + _TRACECONTEXT.fields_by_name['spanID']._options = None + _TRACECONTEXT.fields_by_name['spanID']._serialized_options = b'\030\001' + _ORCHESTRATIONSTATUS._serialized_start=11416 + _ORCHESTRATIONSTATUS._serialized_end=11725 + _ORCHESTRATIONINSTANCE._serialized_start=156 + _ORCHESTRATIONINSTANCE._serialized_end=250 + _ACTIVITYREQUEST._serialized_start=253 + _ACTIVITYREQUEST._serialized_end=447 + _ACTIVITYRESPONSE._serialized_start=450 + _ACTIVITYRESPONSE._serialized_end=595 + _TASKFAILUREDETAILS._serialized_start=598 + _TASKFAILUREDETAILS._serialized_end=776 + _PARENTINSTANCEINFO._serialized_start=779 + _PARENTINSTANCEINFO._serialized_end=970 + _TRACECONTEXT._serialized_start=972 + _TRACECONTEXT._serialized_end=1077 + _EXECUTIONSTARTEDEVENT._serialized_start=1080 + _EXECUTIONSTARTEDEVENT._serialized_end=1472 + _EXECUTIONCOMPLETEDEVENT._serialized_start=1475 + _EXECUTIONCOMPLETEDEVENT._serialized_end=1642 + _EXECUTIONTERMINATEDEVENT._serialized_start=1644 + _EXECUTIONTERMINATEDEVENT._serialized_end=1732 + _TASKSCHEDULEDEVENT._serialized_start=1735 + _TASKSCHEDULEDEVENT._serialized_end=1904 + _TASKCOMPLETEDEVENT._serialized_start=1906 + _TASKCOMPLETEDEVENT._serialized_end=1997 + _TASKFAILEDEVENT._serialized_start=1999 + _TASKFAILEDEVENT._serialized_end=2086 + _SUBORCHESTRATIONINSTANCECREATEDEVENT._serialized_start=2089 + _SUBORCHESTRATIONINSTANCECREATEDEVENT._serialized_end=2296 + _SUBORCHESTRATIONINSTANCECOMPLETEDEVENT._serialized_start=2298 + _SUBORCHESTRATIONINSTANCECOMPLETEDEVENT._serialized_end=2409 + _SUBORCHESTRATIONINSTANCEFAILEDEVENT._serialized_start=2411 + _SUBORCHESTRATIONINSTANCEFAILEDEVENT._serialized_end=2518 + _TIMERCREATEDEVENT._serialized_start=2520 + _TIMERCREATEDEVENT._serialized_end=2583 + _TIMERFIREDEVENT._serialized_start=2585 + _TIMERFIREDEVENT._serialized_end=2663 + _ORCHESTRATORSTARTEDEVENT._serialized_start=2665 + _ORCHESTRATORSTARTEDEVENT._serialized_end=2691 + _ORCHESTRATORCOMPLETEDEVENT._serialized_start=2693 + _ORCHESTRATORCOMPLETEDEVENT._serialized_end=2721 + _EVENTSENTEVENT._serialized_start=2723 + _EVENTSENTEVENT._serialized_end=2818 + _EVENTRAISEDEVENT._serialized_start=2820 + _EVENTRAISEDEVENT._serialized_end=2897 + _GENERICEVENT._serialized_start=2899 + _GENERICEVENT._serialized_end=2927 + _HISTORYSTATEEVENT._serialized_start=2929 + _HISTORYSTATEEVENT._serialized_end=2997 + _CONTINUEASNEWEVENT._serialized_start=2999 + _CONTINUEASNEWEVENT._serialized_end=3064 + _EXECUTIONSUSPENDEDEVENT._serialized_start=3066 + _EXECUTIONSUSPENDEDEVENT._serialized_end=3136 + _EXECUTIONRESUMEDEVENT._serialized_start=3138 + _EXECUTIONRESUMEDEVENT._serialized_end=3206 + _HISTORYEVENT._serialized_start=3209 + _HISTORYEVENT._serialized_end=4367 + _SCHEDULETASKACTION._serialized_start=4369 + _SCHEDULETASKACTION._serialized_end=4495 + _CREATESUBORCHESTRATIONACTION._serialized_start=4498 + _CREATESUBORCHESTRATIONACTION._serialized_end=4654 + _CREATETIMERACTION._serialized_start=4656 + _CREATETIMERACTION._serialized_end=4719 + _SENDEVENTACTION._serialized_start=4721 + _SENDEVENTACTION._serialized_end=4838 + _COMPLETEORCHESTRATIONACTION._serialized_start=4841 + _COMPLETEORCHESTRATIONACTION._serialized_end=5149 + _TERMINATEORCHESTRATIONACTION._serialized_start=5151 + _TERMINATEORCHESTRATIONACTION._serialized_end=5264 + _ORCHESTRATORACTION._serialized_start=5267 + _ORCHESTRATORACTION._serialized_end=5645 + _ORCHESTRATORREQUEST._serialized_start=5648 + _ORCHESTRATORREQUEST._serialized_end=5866 + _ORCHESTRATORRESPONSE._serialized_start=5869 + _ORCHESTRATORRESPONSE._serialized_end=6001 + _CREATEINSTANCEREQUEST._serialized_start=6004 + _CREATEINSTANCEREQUEST._serialized_end=6214 + _CREATEINSTANCERESPONSE._serialized_start=6216 + _CREATEINSTANCERESPONSE._serialized_end=6260 + _GETINSTANCEREQUEST._serialized_start=6262 + _GETINSTANCEREQUEST._serialized_end=6331 + _GETINSTANCERESPONSE._serialized_start=6333 + _GETINSTANCERESPONSE._serialized_end=6419 + _REWINDINSTANCEREQUEST._serialized_start=6421 + _REWINDINSTANCEREQUEST._serialized_end=6510 + _REWINDINSTANCERESPONSE._serialized_start=6512 + _REWINDINSTANCERESPONSE._serialized_end=6536 + _ORCHESTRATIONSTATE._serialized_start=6539 + _ORCHESTRATIONSTATE._serialized_end=7052 + _RAISEEVENTREQUEST._serialized_start=7054 + _RAISEEVENTREQUEST._serialized_end=7152 + _RAISEEVENTRESPONSE._serialized_start=7154 + _RAISEEVENTRESPONSE._serialized_end=7174 + _TERMINATEREQUEST._serialized_start=7176 + _TERMINATEREQUEST._serialized_end=7279 + _TERMINATERESPONSE._serialized_start=7281 + _TERMINATERESPONSE._serialized_end=7300 + _SUSPENDREQUEST._serialized_start=7302 + _SUSPENDREQUEST._serialized_end=7384 + _SUSPENDRESPONSE._serialized_start=7386 + _SUSPENDRESPONSE._serialized_end=7403 + _RESUMEREQUEST._serialized_start=7405 + _RESUMEREQUEST._serialized_end=7486 + _RESUMERESPONSE._serialized_start=7488 + _RESUMERESPONSE._serialized_end=7504 + _QUERYINSTANCESREQUEST._serialized_start=7506 + _QUERYINSTANCESREQUEST._serialized_end=7560 + _INSTANCEQUERY._serialized_start=7563 + _INSTANCEQUERY._serialized_end=7949 + _QUERYINSTANCESRESPONSE._serialized_start=7952 + _QUERYINSTANCESRESPONSE._serialized_end=8082 + _PURGEINSTANCESREQUEST._serialized_start=8084 + _PURGEINSTANCESREQUEST._serialized_end=8193 + _PURGEINSTANCEFILTER._serialized_start=8196 + _PURGEINSTANCEFILTER._serialized_end=8366 + _PURGEINSTANCESRESPONSE._serialized_start=8368 + _PURGEINSTANCESRESPONSE._serialized_end=8422 + _CREATETASKHUBREQUEST._serialized_start=8424 + _CREATETASKHUBREQUEST._serialized_end=8472 + _CREATETASKHUBRESPONSE._serialized_start=8474 + _CREATETASKHUBRESPONSE._serialized_end=8497 + _DELETETASKHUBREQUEST._serialized_start=8499 + _DELETETASKHUBREQUEST._serialized_end=8521 + _DELETETASKHUBRESPONSE._serialized_start=8523 + _DELETETASKHUBRESPONSE._serialized_end=8546 + _SIGNALENTITYREQUEST._serialized_start=8549 + _SIGNALENTITYREQUEST._serialized_end=8719 + _SIGNALENTITYRESPONSE._serialized_start=8721 + _SIGNALENTITYRESPONSE._serialized_end=8743 + _GETENTITYREQUEST._serialized_start=8745 + _GETENTITYREQUEST._serialized_end=8805 + _GETENTITYRESPONSE._serialized_start=8807 + _GETENTITYRESPONSE._serialized_end=8875 + _ENTITYQUERY._serialized_start=8878 + _ENTITYQUERY._serialized_end=9209 + _QUERYENTITIESREQUEST._serialized_start=9211 + _QUERYENTITIESREQUEST._serialized_end=9262 + _QUERYENTITIESRESPONSE._serialized_start=9264 + _QUERYENTITIESRESPONSE._serialized_end=9379 + _ENTITYMETADATA._serialized_start=9382 + _ENTITYMETADATA._serialized_end=9601 + _CLEANENTITYSTORAGEREQUEST._serialized_start=9604 + _CLEANENTITYSTORAGEREQUEST._serialized_end=9747 + _CLEANENTITYSTORAGERESPONSE._serialized_start=9750 + _CLEANENTITYSTORAGERESPONSE._serialized_end=9896 + _ORCHESTRATORENTITYPARAMETERS._serialized_start=9898 + _ORCHESTRATORENTITYPARAMETERS._serialized_end=9991 + _ENTITYBATCHREQUEST._serialized_start=9994 + _ENTITYBATCHREQUEST._serialized_end=10124 + _ENTITYBATCHRESULT._serialized_start=10127 + _ENTITYBATCHRESULT._serialized_end=10312 + _OPERATIONREQUEST._serialized_start=10314 + _OPERATIONREQUEST._serialized_end=10415 + _OPERATIONRESULT._serialized_start=10417 + _OPERATIONRESULT._serialized_end=10536 + _OPERATIONRESULTSUCCESS._serialized_start=10538 + _OPERATIONRESULTSUCCESS._serialized_end=10608 + _OPERATIONRESULTFAILURE._serialized_start=10610 + _OPERATIONRESULTFAILURE._serialized_end=10679 + _OPERATIONACTION._serialized_start=10682 + _OPERATIONACTION._serialized_end=10838 + _SENDSIGNALACTION._serialized_start=10841 + _SENDSIGNALACTION._serialized_end=10989 + _STARTNEWORCHESTRATIONACTION._serialized_start=10992 + _STARTNEWORCHESTRATIONACTION._serialized_end=11198 + _GETWORKITEMSREQUEST._serialized_start=11200 + _GETWORKITEMSREQUEST._serialized_end=11221 + _WORKITEM._serialized_start=11224 + _WORKITEM._serialized_end=11389 + _COMPLETETASKRESPONSE._serialized_start=11391 + _COMPLETETASKRESPONSE._serialized_end=11413 + _TASKHUBSIDECARSERVICE._serialized_start=11728 + _TASKHUBSIDECARSERVICE._serialized_end=13132 # @@protoc_insertion_point(module_scope) diff --git a/durabletask/internal/orchestrator_service_pb2.pyi b/durabletask/internal/orchestrator_service_pb2.pyi index aa60be4..afe7254 100644 --- a/durabletask/internal/orchestrator_service_pb2.pyi +++ b/durabletask/internal/orchestrator_service_pb2.pyi @@ -1,4 +1,5 @@ from google.protobuf import timestamp_pb2 as _timestamp_pb2 +from google.protobuf import duration_pb2 as _duration_pb2 from google.protobuf import wrappers_pb2 as _wrappers_pb2 from google.protobuf import empty_pb2 as _empty_pb2 from google.protobuf.internal import containers as _containers @@ -43,6 +44,26 @@ class ActivityResponse(_message.Message): taskId: int def __init__(self, instanceId: _Optional[str] = ..., taskId: _Optional[int] = ..., result: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., failureDetails: _Optional[_Union[TaskFailureDetails, _Mapping]] = ...) -> None: ... +class CleanEntityStorageRequest(_message.Message): + __slots__ = ["continuationToken", "releaseOrphanedLocks", "removeEmptyEntities"] + CONTINUATIONTOKEN_FIELD_NUMBER: _ClassVar[int] + RELEASEORPHANEDLOCKS_FIELD_NUMBER: _ClassVar[int] + REMOVEEMPTYENTITIES_FIELD_NUMBER: _ClassVar[int] + continuationToken: _wrappers_pb2.StringValue + releaseOrphanedLocks: bool + removeEmptyEntities: bool + def __init__(self, continuationToken: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., removeEmptyEntities: bool = ..., releaseOrphanedLocks: bool = ...) -> None: ... + +class CleanEntityStorageResponse(_message.Message): + __slots__ = ["continuationToken", "emptyEntitiesRemoved", "orphanedLocksReleased"] + CONTINUATIONTOKEN_FIELD_NUMBER: _ClassVar[int] + EMPTYENTITIESREMOVED_FIELD_NUMBER: _ClassVar[int] + ORPHANEDLOCKSRELEASED_FIELD_NUMBER: _ClassVar[int] + continuationToken: _wrappers_pb2.StringValue + emptyEntitiesRemoved: int + orphanedLocksReleased: int + def __init__(self, continuationToken: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., emptyEntitiesRemoved: _Optional[int] = ..., orphanedLocksReleased: _Optional[int] = ...) -> None: ... + class CompleteOrchestrationAction(_message.Message): __slots__ = ["carryoverEvents", "details", "failureDetails", "newVersion", "orchestrationStatus", "result"] CARRYOVEREVENTS_FIELD_NUMBER: _ClassVar[int] @@ -125,6 +146,60 @@ class DeleteTaskHubResponse(_message.Message): __slots__ = [] def __init__(self) -> None: ... +class EntityBatchRequest(_message.Message): + __slots__ = ["entityState", "instanceId", "operations"] + ENTITYSTATE_FIELD_NUMBER: _ClassVar[int] + INSTANCEID_FIELD_NUMBER: _ClassVar[int] + OPERATIONS_FIELD_NUMBER: _ClassVar[int] + entityState: _wrappers_pb2.StringValue + instanceId: str + operations: _containers.RepeatedCompositeFieldContainer[OperationRequest] + def __init__(self, instanceId: _Optional[str] = ..., entityState: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., operations: _Optional[_Iterable[_Union[OperationRequest, _Mapping]]] = ...) -> None: ... + +class EntityBatchResult(_message.Message): + __slots__ = ["actions", "entityState", "failureDetails", "results"] + ACTIONS_FIELD_NUMBER: _ClassVar[int] + ENTITYSTATE_FIELD_NUMBER: _ClassVar[int] + FAILUREDETAILS_FIELD_NUMBER: _ClassVar[int] + RESULTS_FIELD_NUMBER: _ClassVar[int] + actions: _containers.RepeatedCompositeFieldContainer[OperationAction] + entityState: _wrappers_pb2.StringValue + failureDetails: TaskFailureDetails + results: _containers.RepeatedCompositeFieldContainer[OperationResult] + def __init__(self, results: _Optional[_Iterable[_Union[OperationResult, _Mapping]]] = ..., actions: _Optional[_Iterable[_Union[OperationAction, _Mapping]]] = ..., entityState: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., failureDetails: _Optional[_Union[TaskFailureDetails, _Mapping]] = ...) -> None: ... + +class EntityMetadata(_message.Message): + __slots__ = ["backlogQueueSize", "instanceId", "lastModifiedTime", "lockedBy", "serializedState"] + BACKLOGQUEUESIZE_FIELD_NUMBER: _ClassVar[int] + INSTANCEID_FIELD_NUMBER: _ClassVar[int] + LASTMODIFIEDTIME_FIELD_NUMBER: _ClassVar[int] + LOCKEDBY_FIELD_NUMBER: _ClassVar[int] + SERIALIZEDSTATE_FIELD_NUMBER: _ClassVar[int] + backlogQueueSize: int + instanceId: str + lastModifiedTime: _timestamp_pb2.Timestamp + lockedBy: _wrappers_pb2.StringValue + serializedState: _wrappers_pb2.StringValue + def __init__(self, instanceId: _Optional[str] = ..., lastModifiedTime: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., backlogQueueSize: _Optional[int] = ..., lockedBy: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., serializedState: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... + +class EntityQuery(_message.Message): + __slots__ = ["continuationToken", "includeState", "includeTransient", "instanceIdStartsWith", "lastModifiedFrom", "lastModifiedTo", "pageSize"] + CONTINUATIONTOKEN_FIELD_NUMBER: _ClassVar[int] + INCLUDESTATE_FIELD_NUMBER: _ClassVar[int] + INCLUDETRANSIENT_FIELD_NUMBER: _ClassVar[int] + INSTANCEIDSTARTSWITH_FIELD_NUMBER: _ClassVar[int] + LASTMODIFIEDFROM_FIELD_NUMBER: _ClassVar[int] + LASTMODIFIEDTO_FIELD_NUMBER: _ClassVar[int] + PAGESIZE_FIELD_NUMBER: _ClassVar[int] + continuationToken: _wrappers_pb2.StringValue + includeState: bool + includeTransient: bool + instanceIdStartsWith: _wrappers_pb2.StringValue + lastModifiedFrom: _timestamp_pb2.Timestamp + lastModifiedTo: _timestamp_pb2.Timestamp + pageSize: _wrappers_pb2.Int32Value + def __init__(self, instanceIdStartsWith: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., lastModifiedFrom: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., lastModifiedTo: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., includeState: bool = ..., includeTransient: bool = ..., pageSize: _Optional[_Union[_wrappers_pb2.Int32Value, _Mapping]] = ..., continuationToken: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... + class EventRaisedEvent(_message.Message): __slots__ = ["input", "name"] INPUT_FIELD_NUMBER: _ClassVar[int] @@ -160,22 +235,24 @@ class ExecutionResumedEvent(_message.Message): def __init__(self, input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... class ExecutionStartedEvent(_message.Message): - __slots__ = ["correlationData", "input", "name", "orchestrationInstance", "parentInstance", "scheduledStartTimestamp", "version"] - CORRELATIONDATA_FIELD_NUMBER: _ClassVar[int] + __slots__ = ["input", "name", "orchestrationInstance", "orchestrationSpanID", "parentInstance", "parentTraceContext", "scheduledStartTimestamp", "version"] INPUT_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] ORCHESTRATIONINSTANCE_FIELD_NUMBER: _ClassVar[int] + ORCHESTRATIONSPANID_FIELD_NUMBER: _ClassVar[int] PARENTINSTANCE_FIELD_NUMBER: _ClassVar[int] + PARENTTRACECONTEXT_FIELD_NUMBER: _ClassVar[int] SCHEDULEDSTARTTIMESTAMP_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] - correlationData: _wrappers_pb2.StringValue input: _wrappers_pb2.StringValue name: str orchestrationInstance: OrchestrationInstance + orchestrationSpanID: _wrappers_pb2.StringValue parentInstance: ParentInstanceInfo + parentTraceContext: TraceContext scheduledStartTimestamp: _timestamp_pb2.Timestamp version: _wrappers_pb2.StringValue - def __init__(self, name: _Optional[str] = ..., version: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., orchestrationInstance: _Optional[_Union[OrchestrationInstance, _Mapping]] = ..., parentInstance: _Optional[_Union[ParentInstanceInfo, _Mapping]] = ..., scheduledStartTimestamp: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., correlationData: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... + def __init__(self, name: _Optional[str] = ..., version: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., orchestrationInstance: _Optional[_Union[OrchestrationInstance, _Mapping]] = ..., parentInstance: _Optional[_Union[ParentInstanceInfo, _Mapping]] = ..., scheduledStartTimestamp: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., parentTraceContext: _Optional[_Union[TraceContext, _Mapping]] = ..., orchestrationSpanID: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... class ExecutionSuspendedEvent(_message.Message): __slots__ = ["input"] @@ -184,10 +261,12 @@ class ExecutionSuspendedEvent(_message.Message): def __init__(self, input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... class ExecutionTerminatedEvent(_message.Message): - __slots__ = ["input"] + __slots__ = ["input", "recurse"] INPUT_FIELD_NUMBER: _ClassVar[int] + RECURSE_FIELD_NUMBER: _ClassVar[int] input: _wrappers_pb2.StringValue - def __init__(self, input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... + recurse: bool + def __init__(self, input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., recurse: bool = ...) -> None: ... class GenericEvent(_message.Message): __slots__ = ["data"] @@ -195,6 +274,22 @@ class GenericEvent(_message.Message): data: str def __init__(self, data: _Optional[str] = ...) -> None: ... +class GetEntityRequest(_message.Message): + __slots__ = ["includeState", "instanceId"] + INCLUDESTATE_FIELD_NUMBER: _ClassVar[int] + INSTANCEID_FIELD_NUMBER: _ClassVar[int] + includeState: bool + instanceId: str + def __init__(self, instanceId: _Optional[str] = ..., includeState: bool = ...) -> None: ... + +class GetEntityResponse(_message.Message): + __slots__ = ["entity", "exists"] + ENTITY_FIELD_NUMBER: _ClassVar[int] + EXISTS_FIELD_NUMBER: _ClassVar[int] + entity: EntityMetadata + exists: bool + def __init__(self, exists: bool = ..., entity: _Optional[_Union[EntityMetadata, _Mapping]] = ...) -> None: ... + class GetInstanceRequest(_message.Message): __slots__ = ["getInputsAndOutputs", "instanceId"] GETINPUTSANDOUTPUTS_FIELD_NUMBER: _ClassVar[int] @@ -289,6 +384,46 @@ class InstanceQuery(_message.Message): taskHubNames: _containers.RepeatedCompositeFieldContainer[_wrappers_pb2.StringValue] def __init__(self, runtimeStatus: _Optional[_Iterable[_Union[OrchestrationStatus, str]]] = ..., createdTimeFrom: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., createdTimeTo: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., taskHubNames: _Optional[_Iterable[_Union[_wrappers_pb2.StringValue, _Mapping]]] = ..., maxInstanceCount: _Optional[int] = ..., continuationToken: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., instanceIdPrefix: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., fetchInputsAndOutputs: bool = ...) -> None: ... +class OperationAction(_message.Message): + __slots__ = ["id", "sendSignal", "startNewOrchestration"] + ID_FIELD_NUMBER: _ClassVar[int] + SENDSIGNAL_FIELD_NUMBER: _ClassVar[int] + STARTNEWORCHESTRATION_FIELD_NUMBER: _ClassVar[int] + id: int + sendSignal: SendSignalAction + startNewOrchestration: StartNewOrchestrationAction + def __init__(self, id: _Optional[int] = ..., sendSignal: _Optional[_Union[SendSignalAction, _Mapping]] = ..., startNewOrchestration: _Optional[_Union[StartNewOrchestrationAction, _Mapping]] = ...) -> None: ... + +class OperationRequest(_message.Message): + __slots__ = ["input", "operation", "requestId"] + INPUT_FIELD_NUMBER: _ClassVar[int] + OPERATION_FIELD_NUMBER: _ClassVar[int] + REQUESTID_FIELD_NUMBER: _ClassVar[int] + input: _wrappers_pb2.StringValue + operation: str + requestId: str + def __init__(self, operation: _Optional[str] = ..., requestId: _Optional[str] = ..., input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... + +class OperationResult(_message.Message): + __slots__ = ["failure", "success"] + FAILURE_FIELD_NUMBER: _ClassVar[int] + SUCCESS_FIELD_NUMBER: _ClassVar[int] + failure: OperationResultFailure + success: OperationResultSuccess + def __init__(self, success: _Optional[_Union[OperationResultSuccess, _Mapping]] = ..., failure: _Optional[_Union[OperationResultFailure, _Mapping]] = ...) -> None: ... + +class OperationResultFailure(_message.Message): + __slots__ = ["failureDetails"] + FAILUREDETAILS_FIELD_NUMBER: _ClassVar[int] + failureDetails: TaskFailureDetails + def __init__(self, failureDetails: _Optional[_Union[TaskFailureDetails, _Mapping]] = ...) -> None: ... + +class OperationResultSuccess(_message.Message): + __slots__ = ["result"] + RESULT_FIELD_NUMBER: _ClassVar[int] + result: _wrappers_pb2.StringValue + def __init__(self, result: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... + class OrchestrationInstance(_message.Message): __slots__ = ["executionId", "instanceId"] EXECUTIONID_FIELD_NUMBER: _ClassVar[int] @@ -324,36 +459,46 @@ class OrchestrationState(_message.Message): def __init__(self, instanceId: _Optional[str] = ..., name: _Optional[str] = ..., version: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., orchestrationStatus: _Optional[_Union[OrchestrationStatus, str]] = ..., scheduledStartTimestamp: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., createdTimestamp: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., lastUpdatedTimestamp: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., output: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., customStatus: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., failureDetails: _Optional[_Union[TaskFailureDetails, _Mapping]] = ...) -> None: ... class OrchestratorAction(_message.Message): - __slots__ = ["completeOrchestration", "createSubOrchestration", "createTimer", "id", "scheduleTask", "sendEvent"] + __slots__ = ["completeOrchestration", "createSubOrchestration", "createTimer", "id", "scheduleTask", "sendEvent", "terminateOrchestration"] COMPLETEORCHESTRATION_FIELD_NUMBER: _ClassVar[int] CREATESUBORCHESTRATION_FIELD_NUMBER: _ClassVar[int] CREATETIMER_FIELD_NUMBER: _ClassVar[int] ID_FIELD_NUMBER: _ClassVar[int] SCHEDULETASK_FIELD_NUMBER: _ClassVar[int] SENDEVENT_FIELD_NUMBER: _ClassVar[int] + TERMINATEORCHESTRATION_FIELD_NUMBER: _ClassVar[int] completeOrchestration: CompleteOrchestrationAction createSubOrchestration: CreateSubOrchestrationAction createTimer: CreateTimerAction id: int scheduleTask: ScheduleTaskAction sendEvent: SendEventAction - def __init__(self, id: _Optional[int] = ..., scheduleTask: _Optional[_Union[ScheduleTaskAction, _Mapping]] = ..., createSubOrchestration: _Optional[_Union[CreateSubOrchestrationAction, _Mapping]] = ..., createTimer: _Optional[_Union[CreateTimerAction, _Mapping]] = ..., sendEvent: _Optional[_Union[SendEventAction, _Mapping]] = ..., completeOrchestration: _Optional[_Union[CompleteOrchestrationAction, _Mapping]] = ...) -> None: ... + terminateOrchestration: TerminateOrchestrationAction + def __init__(self, id: _Optional[int] = ..., scheduleTask: _Optional[_Union[ScheduleTaskAction, _Mapping]] = ..., createSubOrchestration: _Optional[_Union[CreateSubOrchestrationAction, _Mapping]] = ..., createTimer: _Optional[_Union[CreateTimerAction, _Mapping]] = ..., sendEvent: _Optional[_Union[SendEventAction, _Mapping]] = ..., completeOrchestration: _Optional[_Union[CompleteOrchestrationAction, _Mapping]] = ..., terminateOrchestration: _Optional[_Union[TerminateOrchestrationAction, _Mapping]] = ...) -> None: ... class OrchestratorCompletedEvent(_message.Message): __slots__ = [] def __init__(self) -> None: ... +class OrchestratorEntityParameters(_message.Message): + __slots__ = ["entityMessageReorderWindow"] + ENTITYMESSAGEREORDERWINDOW_FIELD_NUMBER: _ClassVar[int] + entityMessageReorderWindow: _duration_pb2.Duration + def __init__(self, entityMessageReorderWindow: _Optional[_Union[_duration_pb2.Duration, _Mapping]] = ...) -> None: ... + class OrchestratorRequest(_message.Message): - __slots__ = ["executionId", "instanceId", "newEvents", "pastEvents"] + __slots__ = ["entityParameters", "executionId", "instanceId", "newEvents", "pastEvents"] + ENTITYPARAMETERS_FIELD_NUMBER: _ClassVar[int] EXECUTIONID_FIELD_NUMBER: _ClassVar[int] INSTANCEID_FIELD_NUMBER: _ClassVar[int] NEWEVENTS_FIELD_NUMBER: _ClassVar[int] PASTEVENTS_FIELD_NUMBER: _ClassVar[int] + entityParameters: OrchestratorEntityParameters executionId: _wrappers_pb2.StringValue instanceId: str newEvents: _containers.RepeatedCompositeFieldContainer[HistoryEvent] pastEvents: _containers.RepeatedCompositeFieldContainer[HistoryEvent] - def __init__(self, instanceId: _Optional[str] = ..., executionId: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., pastEvents: _Optional[_Iterable[_Union[HistoryEvent, _Mapping]]] = ..., newEvents: _Optional[_Iterable[_Union[HistoryEvent, _Mapping]]] = ...) -> None: ... + def __init__(self, instanceId: _Optional[str] = ..., executionId: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., pastEvents: _Optional[_Iterable[_Union[HistoryEvent, _Mapping]]] = ..., newEvents: _Optional[_Iterable[_Union[HistoryEvent, _Mapping]]] = ..., entityParameters: _Optional[_Union[OrchestratorEntityParameters, _Mapping]] = ...) -> None: ... class OrchestratorResponse(_message.Message): __slots__ = ["actions", "customStatus", "instanceId"] @@ -405,6 +550,20 @@ class PurgeInstancesResponse(_message.Message): deletedInstanceCount: int def __init__(self, deletedInstanceCount: _Optional[int] = ...) -> None: ... +class QueryEntitiesRequest(_message.Message): + __slots__ = ["query"] + QUERY_FIELD_NUMBER: _ClassVar[int] + query: EntityQuery + def __init__(self, query: _Optional[_Union[EntityQuery, _Mapping]] = ...) -> None: ... + +class QueryEntitiesResponse(_message.Message): + __slots__ = ["continuationToken", "entities"] + CONTINUATIONTOKEN_FIELD_NUMBER: _ClassVar[int] + ENTITIES_FIELD_NUMBER: _ClassVar[int] + continuationToken: _wrappers_pb2.StringValue + entities: _containers.RepeatedCompositeFieldContainer[EntityMetadata] + def __init__(self, entities: _Optional[_Iterable[_Union[EntityMetadata, _Mapping]]] = ..., continuationToken: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... + class QueryInstancesRequest(_message.Message): __slots__ = ["query"] QUERY_FIELD_NUMBER: _ClassVar[int] @@ -477,6 +636,50 @@ class SendEventAction(_message.Message): name: str def __init__(self, instance: _Optional[_Union[OrchestrationInstance, _Mapping]] = ..., name: _Optional[str] = ..., data: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... +class SendSignalAction(_message.Message): + __slots__ = ["input", "instanceId", "name", "scheduledTime"] + INPUT_FIELD_NUMBER: _ClassVar[int] + INSTANCEID_FIELD_NUMBER: _ClassVar[int] + NAME_FIELD_NUMBER: _ClassVar[int] + SCHEDULEDTIME_FIELD_NUMBER: _ClassVar[int] + input: _wrappers_pb2.StringValue + instanceId: str + name: str + scheduledTime: _timestamp_pb2.Timestamp + def __init__(self, instanceId: _Optional[str] = ..., name: _Optional[str] = ..., input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., scheduledTime: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ...) -> None: ... + +class SignalEntityRequest(_message.Message): + __slots__ = ["input", "instanceId", "name", "requestId", "scheduledTime"] + INPUT_FIELD_NUMBER: _ClassVar[int] + INSTANCEID_FIELD_NUMBER: _ClassVar[int] + NAME_FIELD_NUMBER: _ClassVar[int] + REQUESTID_FIELD_NUMBER: _ClassVar[int] + SCHEDULEDTIME_FIELD_NUMBER: _ClassVar[int] + input: _wrappers_pb2.StringValue + instanceId: str + name: str + requestId: str + scheduledTime: _timestamp_pb2.Timestamp + def __init__(self, instanceId: _Optional[str] = ..., name: _Optional[str] = ..., input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., requestId: _Optional[str] = ..., scheduledTime: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ...) -> None: ... + +class SignalEntityResponse(_message.Message): + __slots__ = [] + def __init__(self) -> None: ... + +class StartNewOrchestrationAction(_message.Message): + __slots__ = ["input", "instanceId", "name", "scheduledTime", "version"] + INPUT_FIELD_NUMBER: _ClassVar[int] + INSTANCEID_FIELD_NUMBER: _ClassVar[int] + NAME_FIELD_NUMBER: _ClassVar[int] + SCHEDULEDTIME_FIELD_NUMBER: _ClassVar[int] + VERSION_FIELD_NUMBER: _ClassVar[int] + input: _wrappers_pb2.StringValue + instanceId: str + name: str + scheduledTime: _timestamp_pb2.Timestamp + version: _wrappers_pb2.StringValue + def __init__(self, instanceId: _Optional[str] = ..., name: _Optional[str] = ..., version: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., scheduledTime: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ...) -> None: ... + class SubOrchestrationInstanceCompletedEvent(_message.Message): __slots__ = ["result", "taskScheduledId"] RESULT_FIELD_NUMBER: _ClassVar[int] @@ -486,16 +689,18 @@ class SubOrchestrationInstanceCompletedEvent(_message.Message): def __init__(self, taskScheduledId: _Optional[int] = ..., result: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... class SubOrchestrationInstanceCreatedEvent(_message.Message): - __slots__ = ["input", "instanceId", "name", "version"] + __slots__ = ["input", "instanceId", "name", "parentTraceContext", "version"] INPUT_FIELD_NUMBER: _ClassVar[int] INSTANCEID_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] + PARENTTRACECONTEXT_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] input: _wrappers_pb2.StringValue instanceId: str name: str + parentTraceContext: TraceContext version: _wrappers_pb2.StringValue - def __init__(self, instanceId: _Optional[str] = ..., name: _Optional[str] = ..., version: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... + def __init__(self, instanceId: _Optional[str] = ..., name: _Optional[str] = ..., version: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., parentTraceContext: _Optional[_Union[TraceContext, _Mapping]] = ...) -> None: ... class SubOrchestrationInstanceFailedEvent(_message.Message): __slots__ = ["failureDetails", "taskScheduledId"] @@ -548,22 +753,36 @@ class TaskFailureDetails(_message.Message): def __init__(self, errorType: _Optional[str] = ..., errorMessage: _Optional[str] = ..., stackTrace: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., innerFailure: _Optional[_Union[TaskFailureDetails, _Mapping]] = ..., isNonRetriable: bool = ...) -> None: ... class TaskScheduledEvent(_message.Message): - __slots__ = ["input", "name", "version"] + __slots__ = ["input", "name", "parentTraceContext", "version"] INPUT_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] + PARENTTRACECONTEXT_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] input: _wrappers_pb2.StringValue name: str + parentTraceContext: TraceContext version: _wrappers_pb2.StringValue - def __init__(self, name: _Optional[str] = ..., version: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... + def __init__(self, name: _Optional[str] = ..., version: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., input: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., parentTraceContext: _Optional[_Union[TraceContext, _Mapping]] = ...) -> None: ... + +class TerminateOrchestrationAction(_message.Message): + __slots__ = ["instanceId", "reason", "recurse"] + INSTANCEID_FIELD_NUMBER: _ClassVar[int] + REASON_FIELD_NUMBER: _ClassVar[int] + RECURSE_FIELD_NUMBER: _ClassVar[int] + instanceId: str + reason: _wrappers_pb2.StringValue + recurse: bool + def __init__(self, instanceId: _Optional[str] = ..., reason: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., recurse: bool = ...) -> None: ... class TerminateRequest(_message.Message): - __slots__ = ["instanceId", "output"] + __slots__ = ["instanceId", "output", "recursive"] INSTANCEID_FIELD_NUMBER: _ClassVar[int] OUTPUT_FIELD_NUMBER: _ClassVar[int] + RECURSIVE_FIELD_NUMBER: _ClassVar[int] instanceId: str output: _wrappers_pb2.StringValue - def __init__(self, instanceId: _Optional[str] = ..., output: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... + recursive: bool + def __init__(self, instanceId: _Optional[str] = ..., output: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ..., recursive: bool = ...) -> None: ... class TerminateResponse(_message.Message): __slots__ = [] @@ -583,13 +802,25 @@ class TimerFiredEvent(_message.Message): timerId: int def __init__(self, fireAt: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., timerId: _Optional[int] = ...) -> None: ... +class TraceContext(_message.Message): + __slots__ = ["spanID", "traceParent", "traceState"] + SPANID_FIELD_NUMBER: _ClassVar[int] + TRACEPARENT_FIELD_NUMBER: _ClassVar[int] + TRACESTATE_FIELD_NUMBER: _ClassVar[int] + spanID: str + traceParent: str + traceState: _wrappers_pb2.StringValue + def __init__(self, traceParent: _Optional[str] = ..., spanID: _Optional[str] = ..., traceState: _Optional[_Union[_wrappers_pb2.StringValue, _Mapping]] = ...) -> None: ... + class WorkItem(_message.Message): - __slots__ = ["activityRequest", "orchestratorRequest"] + __slots__ = ["activityRequest", "entityRequest", "orchestratorRequest"] ACTIVITYREQUEST_FIELD_NUMBER: _ClassVar[int] + ENTITYREQUEST_FIELD_NUMBER: _ClassVar[int] ORCHESTRATORREQUEST_FIELD_NUMBER: _ClassVar[int] activityRequest: ActivityRequest + entityRequest: EntityBatchRequest orchestratorRequest: OrchestratorRequest - def __init__(self, orchestratorRequest: _Optional[_Union[OrchestratorRequest, _Mapping]] = ..., activityRequest: _Optional[_Union[ActivityRequest, _Mapping]] = ...) -> None: ... + def __init__(self, orchestratorRequest: _Optional[_Union[OrchestratorRequest, _Mapping]] = ..., activityRequest: _Optional[_Union[ActivityRequest, _Mapping]] = ..., entityRequest: _Optional[_Union[EntityBatchRequest, _Mapping]] = ...) -> None: ... class OrchestrationStatus(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = [] diff --git a/durabletask/internal/orchestrator_service_pb2_grpc.py b/durabletask/internal/orchestrator_service_pb2_grpc.py index 9c08bd8..287b4d6 100644 --- a/durabletask/internal/orchestrator_service_pb2_grpc.py +++ b/durabletask/internal/orchestrator_service_pb2_grpc.py @@ -17,90 +17,115 @@ def __init__(self, channel): channel: A grpc.Channel. """ self.Hello = channel.unary_unary( - '/TaskHubSidecarService/Hello', - request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - ) + '/TaskHubSidecarService/Hello', + request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, + response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, + ) self.StartInstance = channel.unary_unary( - '/TaskHubSidecarService/StartInstance', - request_serializer=orchestrator__service__pb2.CreateInstanceRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.CreateInstanceResponse.FromString, - ) + '/TaskHubSidecarService/StartInstance', + request_serializer=orchestrator__service__pb2.CreateInstanceRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.CreateInstanceResponse.FromString, + ) self.GetInstance = channel.unary_unary( - '/TaskHubSidecarService/GetInstance', - request_serializer=orchestrator__service__pb2.GetInstanceRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.GetInstanceResponse.FromString, - ) + '/TaskHubSidecarService/GetInstance', + request_serializer=orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.GetInstanceResponse.FromString, + ) self.RewindInstance = channel.unary_unary( - '/TaskHubSidecarService/RewindInstance', - request_serializer=orchestrator__service__pb2.RewindInstanceRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.RewindInstanceResponse.FromString, - ) + '/TaskHubSidecarService/RewindInstance', + request_serializer=orchestrator__service__pb2.RewindInstanceRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.RewindInstanceResponse.FromString, + ) self.WaitForInstanceStart = channel.unary_unary( - '/TaskHubSidecarService/WaitForInstanceStart', - request_serializer=orchestrator__service__pb2.GetInstanceRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.GetInstanceResponse.FromString, - ) + '/TaskHubSidecarService/WaitForInstanceStart', + request_serializer=orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.GetInstanceResponse.FromString, + ) self.WaitForInstanceCompletion = channel.unary_unary( - '/TaskHubSidecarService/WaitForInstanceCompletion', - request_serializer=orchestrator__service__pb2.GetInstanceRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.GetInstanceResponse.FromString, - ) + '/TaskHubSidecarService/WaitForInstanceCompletion', + request_serializer=orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.GetInstanceResponse.FromString, + ) self.RaiseEvent = channel.unary_unary( - '/TaskHubSidecarService/RaiseEvent', - request_serializer=orchestrator__service__pb2.RaiseEventRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.RaiseEventResponse.FromString, - ) + '/TaskHubSidecarService/RaiseEvent', + request_serializer=orchestrator__service__pb2.RaiseEventRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.RaiseEventResponse.FromString, + ) self.TerminateInstance = channel.unary_unary( - '/TaskHubSidecarService/TerminateInstance', - request_serializer=orchestrator__service__pb2.TerminateRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.TerminateResponse.FromString, - ) + '/TaskHubSidecarService/TerminateInstance', + request_serializer=orchestrator__service__pb2.TerminateRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.TerminateResponse.FromString, + ) self.SuspendInstance = channel.unary_unary( - '/TaskHubSidecarService/SuspendInstance', - request_serializer=orchestrator__service__pb2.SuspendRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.SuspendResponse.FromString, - ) + '/TaskHubSidecarService/SuspendInstance', + request_serializer=orchestrator__service__pb2.SuspendRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.SuspendResponse.FromString, + ) self.ResumeInstance = channel.unary_unary( - '/TaskHubSidecarService/ResumeInstance', - request_serializer=orchestrator__service__pb2.ResumeRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.ResumeResponse.FromString, - ) + '/TaskHubSidecarService/ResumeInstance', + request_serializer=orchestrator__service__pb2.ResumeRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.ResumeResponse.FromString, + ) self.QueryInstances = channel.unary_unary( - '/TaskHubSidecarService/QueryInstances', - request_serializer=orchestrator__service__pb2.QueryInstancesRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.QueryInstancesResponse.FromString, - ) + '/TaskHubSidecarService/QueryInstances', + request_serializer=orchestrator__service__pb2.QueryInstancesRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.QueryInstancesResponse.FromString, + ) self.PurgeInstances = channel.unary_unary( - '/TaskHubSidecarService/PurgeInstances', - request_serializer=orchestrator__service__pb2.PurgeInstancesRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.PurgeInstancesResponse.FromString, - ) + '/TaskHubSidecarService/PurgeInstances', + request_serializer=orchestrator__service__pb2.PurgeInstancesRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.PurgeInstancesResponse.FromString, + ) self.GetWorkItems = channel.unary_stream( - '/TaskHubSidecarService/GetWorkItems', - request_serializer=orchestrator__service__pb2.GetWorkItemsRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.WorkItem.FromString, - ) + '/TaskHubSidecarService/GetWorkItems', + request_serializer=orchestrator__service__pb2.GetWorkItemsRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.WorkItem.FromString, + ) self.CompleteActivityTask = channel.unary_unary( - '/TaskHubSidecarService/CompleteActivityTask', - request_serializer=orchestrator__service__pb2.ActivityResponse.SerializeToString, - response_deserializer=orchestrator__service__pb2.CompleteTaskResponse.FromString, - ) + '/TaskHubSidecarService/CompleteActivityTask', + request_serializer=orchestrator__service__pb2.ActivityResponse.SerializeToString, + response_deserializer=orchestrator__service__pb2.CompleteTaskResponse.FromString, + ) self.CompleteOrchestratorTask = channel.unary_unary( - '/TaskHubSidecarService/CompleteOrchestratorTask', - request_serializer=orchestrator__service__pb2.OrchestratorResponse.SerializeToString, - response_deserializer=orchestrator__service__pb2.CompleteTaskResponse.FromString, - ) + '/TaskHubSidecarService/CompleteOrchestratorTask', + request_serializer=orchestrator__service__pb2.OrchestratorResponse.SerializeToString, + response_deserializer=orchestrator__service__pb2.CompleteTaskResponse.FromString, + ) + self.CompleteEntityTask = channel.unary_unary( + '/TaskHubSidecarService/CompleteEntityTask', + request_serializer=orchestrator__service__pb2.EntityBatchResult.SerializeToString, + response_deserializer=orchestrator__service__pb2.CompleteTaskResponse.FromString, + ) self.CreateTaskHub = channel.unary_unary( - '/TaskHubSidecarService/CreateTaskHub', - request_serializer=orchestrator__service__pb2.CreateTaskHubRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.CreateTaskHubResponse.FromString, - ) + '/TaskHubSidecarService/CreateTaskHub', + request_serializer=orchestrator__service__pb2.CreateTaskHubRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.CreateTaskHubResponse.FromString, + ) self.DeleteTaskHub = channel.unary_unary( - '/TaskHubSidecarService/DeleteTaskHub', - request_serializer=orchestrator__service__pb2.DeleteTaskHubRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.DeleteTaskHubResponse.FromString, - ) + '/TaskHubSidecarService/DeleteTaskHub', + request_serializer=orchestrator__service__pb2.DeleteTaskHubRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.DeleteTaskHubResponse.FromString, + ) + self.SignalEntity = channel.unary_unary( + '/TaskHubSidecarService/SignalEntity', + request_serializer=orchestrator__service__pb2.SignalEntityRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.SignalEntityResponse.FromString, + ) + self.GetEntity = channel.unary_unary( + '/TaskHubSidecarService/GetEntity', + request_serializer=orchestrator__service__pb2.GetEntityRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.GetEntityResponse.FromString, + ) + self.QueryEntities = channel.unary_unary( + '/TaskHubSidecarService/QueryEntities', + request_serializer=orchestrator__service__pb2.QueryEntitiesRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.QueryEntitiesResponse.FromString, + ) + self.CleanEntityStorage = channel.unary_unary( + '/TaskHubSidecarService/CleanEntityStorage', + request_serializer=orchestrator__service__pb2.CleanEntityStorageRequest.SerializeToString, + response_deserializer=orchestrator__service__pb2.CleanEntityStorageResponse.FromString, + ) class TaskHubSidecarServiceServicer(object): @@ -208,6 +233,12 @@ def CompleteOrchestratorTask(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + def CompleteEntityTask(self, request, context): + """Missing associated documentation comment in .proto file.""" + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + def CreateTaskHub(self, request, context): """Deletes and Creates the necessary resources for the orchestration service and the instance store """ @@ -222,390 +253,527 @@ def DeleteTaskHub(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + def SignalEntity(self, request, context): + """sends a signal to an entity + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def GetEntity(self, request, context): + """get information about a specific entity + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def QueryEntities(self, request, context): + """query entities + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def CleanEntityStorage(self, request, context): + """clean entity storage + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + def add_TaskHubSidecarServiceServicer_to_server(servicer, server): rpc_method_handlers = { - 'Hello': grpc.unary_unary_rpc_method_handler( - servicer.Hello, - request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - ), - 'StartInstance': grpc.unary_unary_rpc_method_handler( - servicer.StartInstance, - request_deserializer=orchestrator__service__pb2.CreateInstanceRequest.FromString, - response_serializer=orchestrator__service__pb2.CreateInstanceResponse.SerializeToString, - ), - 'GetInstance': grpc.unary_unary_rpc_method_handler( - servicer.GetInstance, - request_deserializer=orchestrator__service__pb2.GetInstanceRequest.FromString, - response_serializer=orchestrator__service__pb2.GetInstanceResponse.SerializeToString, - ), - 'RewindInstance': grpc.unary_unary_rpc_method_handler( - servicer.RewindInstance, - request_deserializer=orchestrator__service__pb2.RewindInstanceRequest.FromString, - response_serializer=orchestrator__service__pb2.RewindInstanceResponse.SerializeToString, - ), - 'WaitForInstanceStart': grpc.unary_unary_rpc_method_handler( - servicer.WaitForInstanceStart, - request_deserializer=orchestrator__service__pb2.GetInstanceRequest.FromString, - response_serializer=orchestrator__service__pb2.GetInstanceResponse.SerializeToString, - ), - 'WaitForInstanceCompletion': grpc.unary_unary_rpc_method_handler( - servicer.WaitForInstanceCompletion, - request_deserializer=orchestrator__service__pb2.GetInstanceRequest.FromString, - response_serializer=orchestrator__service__pb2.GetInstanceResponse.SerializeToString, - ), - 'RaiseEvent': grpc.unary_unary_rpc_method_handler( - servicer.RaiseEvent, - request_deserializer=orchestrator__service__pb2.RaiseEventRequest.FromString, - response_serializer=orchestrator__service__pb2.RaiseEventResponse.SerializeToString, - ), - 'TerminateInstance': grpc.unary_unary_rpc_method_handler( - servicer.TerminateInstance, - request_deserializer=orchestrator__service__pb2.TerminateRequest.FromString, - response_serializer=orchestrator__service__pb2.TerminateResponse.SerializeToString, - ), - 'SuspendInstance': grpc.unary_unary_rpc_method_handler( - servicer.SuspendInstance, - request_deserializer=orchestrator__service__pb2.SuspendRequest.FromString, - response_serializer=orchestrator__service__pb2.SuspendResponse.SerializeToString, - ), - 'ResumeInstance': grpc.unary_unary_rpc_method_handler( - servicer.ResumeInstance, - request_deserializer=orchestrator__service__pb2.ResumeRequest.FromString, - response_serializer=orchestrator__service__pb2.ResumeResponse.SerializeToString, - ), - 'QueryInstances': grpc.unary_unary_rpc_method_handler( - servicer.QueryInstances, - request_deserializer=orchestrator__service__pb2.QueryInstancesRequest.FromString, - response_serializer=orchestrator__service__pb2.QueryInstancesResponse.SerializeToString, - ), - 'PurgeInstances': grpc.unary_unary_rpc_method_handler( - servicer.PurgeInstances, - request_deserializer=orchestrator__service__pb2.PurgeInstancesRequest.FromString, - response_serializer=orchestrator__service__pb2.PurgeInstancesResponse.SerializeToString, - ), - 'GetWorkItems': grpc.unary_stream_rpc_method_handler( - servicer.GetWorkItems, - request_deserializer=orchestrator__service__pb2.GetWorkItemsRequest.FromString, - response_serializer=orchestrator__service__pb2.WorkItem.SerializeToString, - ), - 'CompleteActivityTask': grpc.unary_unary_rpc_method_handler( - servicer.CompleteActivityTask, - request_deserializer=orchestrator__service__pb2.ActivityResponse.FromString, - response_serializer=orchestrator__service__pb2.CompleteTaskResponse.SerializeToString, - ), - 'CompleteOrchestratorTask': grpc.unary_unary_rpc_method_handler( - servicer.CompleteOrchestratorTask, - request_deserializer=orchestrator__service__pb2.OrchestratorResponse.FromString, - response_serializer=orchestrator__service__pb2.CompleteTaskResponse.SerializeToString, - ), - 'CreateTaskHub': grpc.unary_unary_rpc_method_handler( - servicer.CreateTaskHub, - request_deserializer=orchestrator__service__pb2.CreateTaskHubRequest.FromString, - response_serializer=orchestrator__service__pb2.CreateTaskHubResponse.SerializeToString, - ), - 'DeleteTaskHub': grpc.unary_unary_rpc_method_handler( - servicer.DeleteTaskHub, - request_deserializer=orchestrator__service__pb2.DeleteTaskHubRequest.FromString, - response_serializer=orchestrator__service__pb2.DeleteTaskHubResponse.SerializeToString, - ), + 'Hello': grpc.unary_unary_rpc_method_handler( + servicer.Hello, + request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, + response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, + ), + 'StartInstance': grpc.unary_unary_rpc_method_handler( + servicer.StartInstance, + request_deserializer=orchestrator__service__pb2.CreateInstanceRequest.FromString, + response_serializer=orchestrator__service__pb2.CreateInstanceResponse.SerializeToString, + ), + 'GetInstance': grpc.unary_unary_rpc_method_handler( + servicer.GetInstance, + request_deserializer=orchestrator__service__pb2.GetInstanceRequest.FromString, + response_serializer=orchestrator__service__pb2.GetInstanceResponse.SerializeToString, + ), + 'RewindInstance': grpc.unary_unary_rpc_method_handler( + servicer.RewindInstance, + request_deserializer=orchestrator__service__pb2.RewindInstanceRequest.FromString, + response_serializer=orchestrator__service__pb2.RewindInstanceResponse.SerializeToString, + ), + 'WaitForInstanceStart': grpc.unary_unary_rpc_method_handler( + servicer.WaitForInstanceStart, + request_deserializer=orchestrator__service__pb2.GetInstanceRequest.FromString, + response_serializer=orchestrator__service__pb2.GetInstanceResponse.SerializeToString, + ), + 'WaitForInstanceCompletion': grpc.unary_unary_rpc_method_handler( + servicer.WaitForInstanceCompletion, + request_deserializer=orchestrator__service__pb2.GetInstanceRequest.FromString, + response_serializer=orchestrator__service__pb2.GetInstanceResponse.SerializeToString, + ), + 'RaiseEvent': grpc.unary_unary_rpc_method_handler( + servicer.RaiseEvent, + request_deserializer=orchestrator__service__pb2.RaiseEventRequest.FromString, + response_serializer=orchestrator__service__pb2.RaiseEventResponse.SerializeToString, + ), + 'TerminateInstance': grpc.unary_unary_rpc_method_handler( + servicer.TerminateInstance, + request_deserializer=orchestrator__service__pb2.TerminateRequest.FromString, + response_serializer=orchestrator__service__pb2.TerminateResponse.SerializeToString, + ), + 'SuspendInstance': grpc.unary_unary_rpc_method_handler( + servicer.SuspendInstance, + request_deserializer=orchestrator__service__pb2.SuspendRequest.FromString, + response_serializer=orchestrator__service__pb2.SuspendResponse.SerializeToString, + ), + 'ResumeInstance': grpc.unary_unary_rpc_method_handler( + servicer.ResumeInstance, + request_deserializer=orchestrator__service__pb2.ResumeRequest.FromString, + response_serializer=orchestrator__service__pb2.ResumeResponse.SerializeToString, + ), + 'QueryInstances': grpc.unary_unary_rpc_method_handler( + servicer.QueryInstances, + request_deserializer=orchestrator__service__pb2.QueryInstancesRequest.FromString, + response_serializer=orchestrator__service__pb2.QueryInstancesResponse.SerializeToString, + ), + 'PurgeInstances': grpc.unary_unary_rpc_method_handler( + servicer.PurgeInstances, + request_deserializer=orchestrator__service__pb2.PurgeInstancesRequest.FromString, + response_serializer=orchestrator__service__pb2.PurgeInstancesResponse.SerializeToString, + ), + 'GetWorkItems': grpc.unary_stream_rpc_method_handler( + servicer.GetWorkItems, + request_deserializer=orchestrator__service__pb2.GetWorkItemsRequest.FromString, + response_serializer=orchestrator__service__pb2.WorkItem.SerializeToString, + ), + 'CompleteActivityTask': grpc.unary_unary_rpc_method_handler( + servicer.CompleteActivityTask, + request_deserializer=orchestrator__service__pb2.ActivityResponse.FromString, + response_serializer=orchestrator__service__pb2.CompleteTaskResponse.SerializeToString, + ), + 'CompleteOrchestratorTask': grpc.unary_unary_rpc_method_handler( + servicer.CompleteOrchestratorTask, + request_deserializer=orchestrator__service__pb2.OrchestratorResponse.FromString, + response_serializer=orchestrator__service__pb2.CompleteTaskResponse.SerializeToString, + ), + 'CompleteEntityTask': grpc.unary_unary_rpc_method_handler( + servicer.CompleteEntityTask, + request_deserializer=orchestrator__service__pb2.EntityBatchResult.FromString, + response_serializer=orchestrator__service__pb2.CompleteTaskResponse.SerializeToString, + ), + 'CreateTaskHub': grpc.unary_unary_rpc_method_handler( + servicer.CreateTaskHub, + request_deserializer=orchestrator__service__pb2.CreateTaskHubRequest.FromString, + response_serializer=orchestrator__service__pb2.CreateTaskHubResponse.SerializeToString, + ), + 'DeleteTaskHub': grpc.unary_unary_rpc_method_handler( + servicer.DeleteTaskHub, + request_deserializer=orchestrator__service__pb2.DeleteTaskHubRequest.FromString, + response_serializer=orchestrator__service__pb2.DeleteTaskHubResponse.SerializeToString, + ), + 'SignalEntity': grpc.unary_unary_rpc_method_handler( + servicer.SignalEntity, + request_deserializer=orchestrator__service__pb2.SignalEntityRequest.FromString, + response_serializer=orchestrator__service__pb2.SignalEntityResponse.SerializeToString, + ), + 'GetEntity': grpc.unary_unary_rpc_method_handler( + servicer.GetEntity, + request_deserializer=orchestrator__service__pb2.GetEntityRequest.FromString, + response_serializer=orchestrator__service__pb2.GetEntityResponse.SerializeToString, + ), + 'QueryEntities': grpc.unary_unary_rpc_method_handler( + servicer.QueryEntities, + request_deserializer=orchestrator__service__pb2.QueryEntitiesRequest.FromString, + response_serializer=orchestrator__service__pb2.QueryEntitiesResponse.SerializeToString, + ), + 'CleanEntityStorage': grpc.unary_unary_rpc_method_handler( + servicer.CleanEntityStorage, + request_deserializer=orchestrator__service__pb2.CleanEntityStorageRequest.FromString, + response_serializer=orchestrator__service__pb2.CleanEntityStorageResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( - 'TaskHubSidecarService', rpc_method_handlers) + 'TaskHubSidecarService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) - # This class is part of an EXPERIMENTAL API. - + # This class is part of an EXPERIMENTAL API. class TaskHubSidecarService(object): """Missing associated documentation comment in .proto file.""" @staticmethod def Hello(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/Hello', - google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, - google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, + google_dot_protobuf_dot_empty__pb2.Empty.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def StartInstance(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/StartInstance', - orchestrator__service__pb2.CreateInstanceRequest.SerializeToString, - orchestrator__service__pb2.CreateInstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.CreateInstanceRequest.SerializeToString, + orchestrator__service__pb2.CreateInstanceResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetInstance(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/GetInstance', - orchestrator__service__pb2.GetInstanceRequest.SerializeToString, - orchestrator__service__pb2.GetInstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + orchestrator__service__pb2.GetInstanceResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def RewindInstance(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/RewindInstance', - orchestrator__service__pb2.RewindInstanceRequest.SerializeToString, - orchestrator__service__pb2.RewindInstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.RewindInstanceRequest.SerializeToString, + orchestrator__service__pb2.RewindInstanceResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def WaitForInstanceStart(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/WaitForInstanceStart', - orchestrator__service__pb2.GetInstanceRequest.SerializeToString, - orchestrator__service__pb2.GetInstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + orchestrator__service__pb2.GetInstanceResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def WaitForInstanceCompletion(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/WaitForInstanceCompletion', - orchestrator__service__pb2.GetInstanceRequest.SerializeToString, - orchestrator__service__pb2.GetInstanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + orchestrator__service__pb2.GetInstanceResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def RaiseEvent(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/RaiseEvent', - orchestrator__service__pb2.RaiseEventRequest.SerializeToString, - orchestrator__service__pb2.RaiseEventResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.RaiseEventRequest.SerializeToString, + orchestrator__service__pb2.RaiseEventResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def TerminateInstance(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/TerminateInstance', - orchestrator__service__pb2.TerminateRequest.SerializeToString, - orchestrator__service__pb2.TerminateResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.TerminateRequest.SerializeToString, + orchestrator__service__pb2.TerminateResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def SuspendInstance(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/SuspendInstance', - orchestrator__service__pb2.SuspendRequest.SerializeToString, - orchestrator__service__pb2.SuspendResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.SuspendRequest.SerializeToString, + orchestrator__service__pb2.SuspendResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ResumeInstance(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/ResumeInstance', - orchestrator__service__pb2.ResumeRequest.SerializeToString, - orchestrator__service__pb2.ResumeResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.ResumeRequest.SerializeToString, + orchestrator__service__pb2.ResumeResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def QueryInstances(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/QueryInstances', - orchestrator__service__pb2.QueryInstancesRequest.SerializeToString, - orchestrator__service__pb2.QueryInstancesResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.QueryInstancesRequest.SerializeToString, + orchestrator__service__pb2.QueryInstancesResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def PurgeInstances(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/PurgeInstances', - orchestrator__service__pb2.PurgeInstancesRequest.SerializeToString, - orchestrator__service__pb2.PurgeInstancesResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.PurgeInstancesRequest.SerializeToString, + orchestrator__service__pb2.PurgeInstancesResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetWorkItems(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_stream(request, target, '/TaskHubSidecarService/GetWorkItems', - orchestrator__service__pb2.GetWorkItemsRequest.SerializeToString, - orchestrator__service__pb2.WorkItem.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.GetWorkItemsRequest.SerializeToString, + orchestrator__service__pb2.WorkItem.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CompleteActivityTask(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/CompleteActivityTask', - orchestrator__service__pb2.ActivityResponse.SerializeToString, - orchestrator__service__pb2.CompleteTaskResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.ActivityResponse.SerializeToString, + orchestrator__service__pb2.CompleteTaskResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CompleteOrchestratorTask(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/CompleteOrchestratorTask', - orchestrator__service__pb2.OrchestratorResponse.SerializeToString, - orchestrator__service__pb2.CompleteTaskResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.OrchestratorResponse.SerializeToString, + orchestrator__service__pb2.CompleteTaskResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def CompleteEntityTask(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/CompleteEntityTask', + orchestrator__service__pb2.EntityBatchResult.SerializeToString, + orchestrator__service__pb2.CompleteTaskResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CreateTaskHub(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/CreateTaskHub', - orchestrator__service__pb2.CreateTaskHubRequest.SerializeToString, - orchestrator__service__pb2.CreateTaskHubResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.CreateTaskHubRequest.SerializeToString, + orchestrator__service__pb2.CreateTaskHubResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def DeleteTaskHub(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/DeleteTaskHub', - orchestrator__service__pb2.DeleteTaskHubRequest.SerializeToString, - orchestrator__service__pb2.DeleteTaskHubResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + orchestrator__service__pb2.DeleteTaskHubRequest.SerializeToString, + orchestrator__service__pb2.DeleteTaskHubResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SignalEntity(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/SignalEntity', + orchestrator__service__pb2.SignalEntityRequest.SerializeToString, + orchestrator__service__pb2.SignalEntityResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def GetEntity(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/GetEntity', + orchestrator__service__pb2.GetEntityRequest.SerializeToString, + orchestrator__service__pb2.GetEntityResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def QueryEntities(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/QueryEntities', + orchestrator__service__pb2.QueryEntitiesRequest.SerializeToString, + orchestrator__service__pb2.QueryEntitiesResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def CleanEntityStorage(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/CleanEntityStorage', + orchestrator__service__pb2.CleanEntityStorageRequest.SerializeToString, + orchestrator__service__pb2.CleanEntityStorageResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) diff --git a/submodules/durabletask-protobuf b/submodules/durabletask-protobuf index 7d68268..3c5d082 160000 --- a/submodules/durabletask-protobuf +++ b/submodules/durabletask-protobuf @@ -1 +1 @@ -Subproject commit 7d6826889eb9b104592ab1020c648517a155ba79 +Subproject commit 3c5d082b5b24adc351a0b8693f023272be18d691