diff --git a/CHANGELOG.md b/CHANGELOG.md index fc4b3d2..a09078d 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -12,6 +12,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 - Added `set_custom_status` orchestrator API ([#31](https://github.com/microsoft/durabletask-python/pull/31)) - contributed by [@famarting](https://github.com/famarting) - Added `purge_orchestration` client API ([#34](https://github.com/microsoft/durabletask-python/pull/34)) - contributed by [@famarting](https://github.com/famarting) +### Changes + +- Protos are compiled with gRPC 1.62.3 / protobuf 3.25.X instead of the latest release. This ensures compatibility with a wider range of grpcio versions for better compatibility with other packages / libraries. + ### Updates - Updated `durabletask-protobuf` submodule reference to latest diff --git a/Makefile b/Makefile index 16b883e..68a9b89 100644 --- a/Makefile +++ b/Makefile @@ -11,7 +11,8 @@ install: python3 -m pip install . gen-proto: -# NOTE: There is currently a hand-edit that we make to the generated orchestrator_service_pb2.py file after it's generated to help resolve import problems. - python3 -m grpc_tools.protoc --proto_path=./submodules/durabletask-protobuf/protos --python_out=./durabletask/internal --pyi_out=./durabletask/internal --grpc_python_out=./durabletask/internal orchestrator_service.proto + cp ./submodules/durabletask-protobuf/protos/orchestrator_service.proto durabletask/internal/orchestrator_service.proto + python3 -m grpc_tools.protoc --proto_path=. --python_out=. --pyi_out=. --grpc_python_out=. ./durabletask/internal/orchestrator_service.proto + rm durabletask/internal/*.proto .PHONY: init test-unit test-e2e gen-proto install diff --git a/README.md b/README.md index 22b3c44..81b5a54 100644 --- a/README.md +++ b/README.md @@ -170,6 +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 +pip3 install -r dev-requirements.txt make gen-proto ``` diff --git a/dev-requirements.txt b/dev-requirements.txt new file mode 100644 index 0000000..119f072 --- /dev/null +++ b/dev-requirements.txt @@ -0,0 +1 @@ +grpcio-tools==1.62.3 # 1.62.X is the latest version before protobuf 1.26.X is used which has breaking changes for Python diff --git a/durabletask/internal/__init__.py b/durabletask/internal/__init__.py deleted file mode 100644 index e69de29..0000000 diff --git a/durabletask/internal/orchestrator_service_pb2.py b/durabletask/internal/orchestrator_service_pb2.py index 6ee3bbb..9c92eac 100644 --- a/durabletask/internal/orchestrator_service_pb2.py +++ b/durabletask/internal/orchestrator_service_pb2.py @@ -1,22 +1,12 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! -# NO CHECKED-IN PROTOBUF GENCODE -# source: orchestrator_service.proto -# Protobuf Python Version: 5.27.2 +# source: durabletask/internal/orchestrator_service.proto +# Protobuf Python Version: 4.25.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool -from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder -_runtime_version.ValidateProtobufRuntimeVersion( - _runtime_version.Domain.PUBLIC, - 5, - 27, - 2, - '', - 'orchestrator_service.proto' -) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -28,196 +18,196 @@ 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/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\"\xed\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\x12)\n\x12parentTraceContext\x18\x06 \x01(\x0b\x32\r.TraceContext\"\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\":\n\x0cGenericEvent\x12*\n\x04\x64\x61ta\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"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\"\xa3\x03\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\x12?\n\x1aorchestrationIdReusePolicy\x18\x06 \x01(\x0b\x32\x1b.OrchestrationIdReusePolicy\x12\x31\n\x0b\x65xecutionId\x18\x07 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12.\n\x04tags\x18\x08 \x03(\x0b\x32 .CreateInstanceRequest.TagsEntry\x1a+\n\tTagsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"w\n\x1aOrchestrationIdReusePolicy\x12-\n\x0foperationStatus\x18\x01 \x03(\x0e\x32\x14.OrchestrationStatus\x12*\n\x06\x61\x63tion\x18\x02 \x01(\x0e\x32\x1a.CreateOrchestrationAction\",\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\"\xa4\x05\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\x12\x31\n\x0b\x65xecutionId\x18\x0c \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x36\n\x12\x63ompletedTimestamp\x18\r \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x36\n\x10parentInstanceId\x18\x0e \x01(\x0b\x32\x1c.google.protobuf.StringValue\"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\"\x80\x01\n\x15PurgeInstancesRequest\x12\x14\n\ninstanceId\x18\x01 \x01(\tH\x00\x12\x33\n\x13purgeInstanceFilter\x18\x02 \x01(\x0b\x32\x14.PurgeInstanceFilterH\x00\x12\x11\n\trecursive\x18\x03 \x01(\x08\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\"\xe1\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\x12!\n\nhealthPing\x18\x04 \x01(\x0b\x32\x0b.HealthPingH\x00\x12\x17\n\x0f\x63ompletionToken\x18\n \x01(\tB\t\n\x07request\"\x16\n\x14\x43ompleteTaskResponse\"\x0c\n\nHealthPing*\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*A\n\x19\x43reateOrchestrationAction\x12\t\n\x05\x45RROR\x10\x00\x12\n\n\x06IGNORE\x10\x01\x12\r\n\tTERMINATE\x10\x02\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') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n/durabletask/internal/orchestrator_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\"\xed\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\x12)\n\x12parentTraceContext\x18\x06 \x01(\x0b\x32\r.TraceContext\"\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\":\n\x0cGenericEvent\x12*\n\x04\x64\x61ta\x18\x01 \x01(\x0b\x32\x1c.google.protobuf.StringValue\"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\"\xa3\x03\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\x12?\n\x1aorchestrationIdReusePolicy\x18\x06 \x01(\x0b\x32\x1b.OrchestrationIdReusePolicy\x12\x31\n\x0b\x65xecutionId\x18\x07 \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12.\n\x04tags\x18\x08 \x03(\x0b\x32 .CreateInstanceRequest.TagsEntry\x1a+\n\tTagsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"w\n\x1aOrchestrationIdReusePolicy\x12-\n\x0foperationStatus\x18\x01 \x03(\x0e\x32\x14.OrchestrationStatus\x12*\n\x06\x61\x63tion\x18\x02 \x01(\x0e\x32\x1a.CreateOrchestrationAction\",\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\"\xa4\x05\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\x12\x31\n\x0b\x65xecutionId\x18\x0c \x01(\x0b\x32\x1c.google.protobuf.StringValue\x12\x36\n\x12\x63ompletedTimestamp\x18\r \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x36\n\x10parentInstanceId\x18\x0e \x01(\x0b\x32\x1c.google.protobuf.StringValue\"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\"\x80\x01\n\x15PurgeInstancesRequest\x12\x14\n\ninstanceId\x18\x01 \x01(\tH\x00\x12\x33\n\x13purgeInstanceFilter\x18\x02 \x01(\x0b\x32\x14.PurgeInstanceFilterH\x00\x12\x11\n\trecursive\x18\x03 \x01(\x08\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\"\xe1\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\x12!\n\nhealthPing\x18\x04 \x01(\x0b\x32\x0b.HealthPingH\x00\x12\x17\n\x0f\x63ompletionToken\x18\n \x01(\tB\t\n\x07request\"\x16\n\x14\x43ompleteTaskResponse\"\x0c\n\nHealthPing*\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*A\n\x19\x43reateOrchestrationAction\x12\t\n\x05\x45RROR\x10\x00\x12\n\n\x06IGNORE\x10\x01\x12\r\n\tTERMINATE\x10\x02\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') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'orchestrator_service_pb2', _globals) -if not _descriptor._USE_C_DESCRIPTORS: - _globals['DESCRIPTOR']._loaded_options = None +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'durabletask.internal.orchestrator_service_pb2', _globals) +if _descriptor._USE_C_DESCRIPTORS == False: + _globals['DESCRIPTOR']._options = None _globals['DESCRIPTOR']._serialized_options = b'\n1com.microsoft.durabletask.implementation.protobufZ\020/internal/protos\252\002\036Microsoft.DurableTask.Protobuf' - _globals['_TRACECONTEXT'].fields_by_name['spanID']._loaded_options = None + _globals['_TRACECONTEXT'].fields_by_name['spanID']._options = None _globals['_TRACECONTEXT'].fields_by_name['spanID']._serialized_options = b'\030\001' - _globals['_CREATEINSTANCEREQUEST_TAGSENTRY']._loaded_options = None + _globals['_CREATEINSTANCEREQUEST_TAGSENTRY']._options = None _globals['_CREATEINSTANCEREQUEST_TAGSENTRY']._serialized_options = b'8\001' - _globals['_ORCHESTRATIONSTATUS']._serialized_start=12076 - _globals['_ORCHESTRATIONSTATUS']._serialized_end=12385 - _globals['_CREATEORCHESTRATIONACTION']._serialized_start=12387 - _globals['_CREATEORCHESTRATIONACTION']._serialized_end=12452 - _globals['_ORCHESTRATIONINSTANCE']._serialized_start=156 - _globals['_ORCHESTRATIONINSTANCE']._serialized_end=250 - _globals['_ACTIVITYREQUEST']._serialized_start=253 - _globals['_ACTIVITYREQUEST']._serialized_end=490 - _globals['_ACTIVITYRESPONSE']._serialized_start=493 - _globals['_ACTIVITYRESPONSE']._serialized_end=638 - _globals['_TASKFAILUREDETAILS']._serialized_start=641 - _globals['_TASKFAILUREDETAILS']._serialized_end=819 - _globals['_PARENTINSTANCEINFO']._serialized_start=822 - _globals['_PARENTINSTANCEINFO']._serialized_end=1013 - _globals['_TRACECONTEXT']._serialized_start=1015 - _globals['_TRACECONTEXT']._serialized_end=1120 - _globals['_EXECUTIONSTARTEDEVENT']._serialized_start=1123 - _globals['_EXECUTIONSTARTEDEVENT']._serialized_end=1515 - _globals['_EXECUTIONCOMPLETEDEVENT']._serialized_start=1518 - _globals['_EXECUTIONCOMPLETEDEVENT']._serialized_end=1685 - _globals['_EXECUTIONTERMINATEDEVENT']._serialized_start=1687 - _globals['_EXECUTIONTERMINATEDEVENT']._serialized_end=1775 - _globals['_TASKSCHEDULEDEVENT']._serialized_start=1778 - _globals['_TASKSCHEDULEDEVENT']._serialized_end=1947 - _globals['_TASKCOMPLETEDEVENT']._serialized_start=1949 - _globals['_TASKCOMPLETEDEVENT']._serialized_end=2040 - _globals['_TASKFAILEDEVENT']._serialized_start=2042 - _globals['_TASKFAILEDEVENT']._serialized_end=2129 - _globals['_SUBORCHESTRATIONINSTANCECREATEDEVENT']._serialized_start=2132 - _globals['_SUBORCHESTRATIONINSTANCECREATEDEVENT']._serialized_end=2339 - _globals['_SUBORCHESTRATIONINSTANCECOMPLETEDEVENT']._serialized_start=2341 - _globals['_SUBORCHESTRATIONINSTANCECOMPLETEDEVENT']._serialized_end=2452 - _globals['_SUBORCHESTRATIONINSTANCEFAILEDEVENT']._serialized_start=2454 - _globals['_SUBORCHESTRATIONINSTANCEFAILEDEVENT']._serialized_end=2561 - _globals['_TIMERCREATEDEVENT']._serialized_start=2563 - _globals['_TIMERCREATEDEVENT']._serialized_end=2626 - _globals['_TIMERFIREDEVENT']._serialized_start=2628 - _globals['_TIMERFIREDEVENT']._serialized_end=2706 - _globals['_ORCHESTRATORSTARTEDEVENT']._serialized_start=2708 - _globals['_ORCHESTRATORSTARTEDEVENT']._serialized_end=2734 - _globals['_ORCHESTRATORCOMPLETEDEVENT']._serialized_start=2736 - _globals['_ORCHESTRATORCOMPLETEDEVENT']._serialized_end=2764 - _globals['_EVENTSENTEVENT']._serialized_start=2766 - _globals['_EVENTSENTEVENT']._serialized_end=2861 - _globals['_EVENTRAISEDEVENT']._serialized_start=2863 - _globals['_EVENTRAISEDEVENT']._serialized_end=2940 - _globals['_GENERICEVENT']._serialized_start=2942 - _globals['_GENERICEVENT']._serialized_end=3000 - _globals['_HISTORYSTATEEVENT']._serialized_start=3002 - _globals['_HISTORYSTATEEVENT']._serialized_end=3070 - _globals['_CONTINUEASNEWEVENT']._serialized_start=3072 - _globals['_CONTINUEASNEWEVENT']._serialized_end=3137 - _globals['_EXECUTIONSUSPENDEDEVENT']._serialized_start=3139 - _globals['_EXECUTIONSUSPENDEDEVENT']._serialized_end=3209 - _globals['_EXECUTIONRESUMEDEVENT']._serialized_start=3211 - _globals['_EXECUTIONRESUMEDEVENT']._serialized_end=3279 - _globals['_HISTORYEVENT']._serialized_start=3282 - _globals['_HISTORYEVENT']._serialized_end=4440 - _globals['_SCHEDULETASKACTION']._serialized_start=4442 - _globals['_SCHEDULETASKACTION']._serialized_end=4568 - _globals['_CREATESUBORCHESTRATIONACTION']._serialized_start=4571 - _globals['_CREATESUBORCHESTRATIONACTION']._serialized_end=4727 - _globals['_CREATETIMERACTION']._serialized_start=4729 - _globals['_CREATETIMERACTION']._serialized_end=4792 - _globals['_SENDEVENTACTION']._serialized_start=4794 - _globals['_SENDEVENTACTION']._serialized_end=4911 - _globals['_COMPLETEORCHESTRATIONACTION']._serialized_start=4914 - _globals['_COMPLETEORCHESTRATIONACTION']._serialized_end=5222 - _globals['_TERMINATEORCHESTRATIONACTION']._serialized_start=5224 - _globals['_TERMINATEORCHESTRATIONACTION']._serialized_end=5337 - _globals['_ORCHESTRATORACTION']._serialized_start=5340 - _globals['_ORCHESTRATORACTION']._serialized_end=5718 - _globals['_ORCHESTRATORREQUEST']._serialized_start=5721 - _globals['_ORCHESTRATORREQUEST']._serialized_end=5939 - _globals['_ORCHESTRATORRESPONSE']._serialized_start=5942 - _globals['_ORCHESTRATORRESPONSE']._serialized_end=6074 - _globals['_CREATEINSTANCEREQUEST']._serialized_start=6077 - _globals['_CREATEINSTANCEREQUEST']._serialized_end=6496 - _globals['_CREATEINSTANCEREQUEST_TAGSENTRY']._serialized_start=6453 - _globals['_CREATEINSTANCEREQUEST_TAGSENTRY']._serialized_end=6496 - _globals['_ORCHESTRATIONIDREUSEPOLICY']._serialized_start=6498 - _globals['_ORCHESTRATIONIDREUSEPOLICY']._serialized_end=6617 - _globals['_CREATEINSTANCERESPONSE']._serialized_start=6619 - _globals['_CREATEINSTANCERESPONSE']._serialized_end=6663 - _globals['_GETINSTANCEREQUEST']._serialized_start=6665 - _globals['_GETINSTANCEREQUEST']._serialized_end=6734 - _globals['_GETINSTANCERESPONSE']._serialized_start=6736 - _globals['_GETINSTANCERESPONSE']._serialized_end=6822 - _globals['_REWINDINSTANCEREQUEST']._serialized_start=6824 - _globals['_REWINDINSTANCEREQUEST']._serialized_end=6913 - _globals['_REWINDINSTANCERESPONSE']._serialized_start=6915 - _globals['_REWINDINSTANCERESPONSE']._serialized_end=6939 - _globals['_ORCHESTRATIONSTATE']._serialized_start=6942 - _globals['_ORCHESTRATIONSTATE']._serialized_end=7618 - _globals['_RAISEEVENTREQUEST']._serialized_start=7620 - _globals['_RAISEEVENTREQUEST']._serialized_end=7718 - _globals['_RAISEEVENTRESPONSE']._serialized_start=7720 - _globals['_RAISEEVENTRESPONSE']._serialized_end=7740 - _globals['_TERMINATEREQUEST']._serialized_start=7742 - _globals['_TERMINATEREQUEST']._serialized_end=7845 - _globals['_TERMINATERESPONSE']._serialized_start=7847 - _globals['_TERMINATERESPONSE']._serialized_end=7866 - _globals['_SUSPENDREQUEST']._serialized_start=7868 - _globals['_SUSPENDREQUEST']._serialized_end=7950 - _globals['_SUSPENDRESPONSE']._serialized_start=7952 - _globals['_SUSPENDRESPONSE']._serialized_end=7969 - _globals['_RESUMEREQUEST']._serialized_start=7971 - _globals['_RESUMEREQUEST']._serialized_end=8052 - _globals['_RESUMERESPONSE']._serialized_start=8054 - _globals['_RESUMERESPONSE']._serialized_end=8070 - _globals['_QUERYINSTANCESREQUEST']._serialized_start=8072 - _globals['_QUERYINSTANCESREQUEST']._serialized_end=8126 - _globals['_INSTANCEQUERY']._serialized_start=8129 - _globals['_INSTANCEQUERY']._serialized_end=8515 - _globals['_QUERYINSTANCESRESPONSE']._serialized_start=8518 - _globals['_QUERYINSTANCESRESPONSE']._serialized_end=8648 - _globals['_PURGEINSTANCESREQUEST']._serialized_start=8651 - _globals['_PURGEINSTANCESREQUEST']._serialized_end=8779 - _globals['_PURGEINSTANCEFILTER']._serialized_start=8782 - _globals['_PURGEINSTANCEFILTER']._serialized_end=8952 - _globals['_PURGEINSTANCESRESPONSE']._serialized_start=8954 - _globals['_PURGEINSTANCESRESPONSE']._serialized_end=9008 - _globals['_CREATETASKHUBREQUEST']._serialized_start=9010 - _globals['_CREATETASKHUBREQUEST']._serialized_end=9058 - _globals['_CREATETASKHUBRESPONSE']._serialized_start=9060 - _globals['_CREATETASKHUBRESPONSE']._serialized_end=9083 - _globals['_DELETETASKHUBREQUEST']._serialized_start=9085 - _globals['_DELETETASKHUBREQUEST']._serialized_end=9107 - _globals['_DELETETASKHUBRESPONSE']._serialized_start=9109 - _globals['_DELETETASKHUBRESPONSE']._serialized_end=9132 - _globals['_SIGNALENTITYREQUEST']._serialized_start=9135 - _globals['_SIGNALENTITYREQUEST']._serialized_end=9305 - _globals['_SIGNALENTITYRESPONSE']._serialized_start=9307 - _globals['_SIGNALENTITYRESPONSE']._serialized_end=9329 - _globals['_GETENTITYREQUEST']._serialized_start=9331 - _globals['_GETENTITYREQUEST']._serialized_end=9391 - _globals['_GETENTITYRESPONSE']._serialized_start=9393 - _globals['_GETENTITYRESPONSE']._serialized_end=9461 - _globals['_ENTITYQUERY']._serialized_start=9464 - _globals['_ENTITYQUERY']._serialized_end=9795 - _globals['_QUERYENTITIESREQUEST']._serialized_start=9797 - _globals['_QUERYENTITIESREQUEST']._serialized_end=9848 - _globals['_QUERYENTITIESRESPONSE']._serialized_start=9850 - _globals['_QUERYENTITIESRESPONSE']._serialized_end=9965 - _globals['_ENTITYMETADATA']._serialized_start=9968 - _globals['_ENTITYMETADATA']._serialized_end=10187 - _globals['_CLEANENTITYSTORAGEREQUEST']._serialized_start=10190 - _globals['_CLEANENTITYSTORAGEREQUEST']._serialized_end=10333 - _globals['_CLEANENTITYSTORAGERESPONSE']._serialized_start=10336 - _globals['_CLEANENTITYSTORAGERESPONSE']._serialized_end=10482 - _globals['_ORCHESTRATORENTITYPARAMETERS']._serialized_start=10484 - _globals['_ORCHESTRATORENTITYPARAMETERS']._serialized_end=10577 - _globals['_ENTITYBATCHREQUEST']._serialized_start=10580 - _globals['_ENTITYBATCHREQUEST']._serialized_end=10710 - _globals['_ENTITYBATCHRESULT']._serialized_start=10713 - _globals['_ENTITYBATCHRESULT']._serialized_end=10898 - _globals['_OPERATIONREQUEST']._serialized_start=10900 - _globals['_OPERATIONREQUEST']._serialized_end=11001 - _globals['_OPERATIONRESULT']._serialized_start=11003 - _globals['_OPERATIONRESULT']._serialized_end=11122 - _globals['_OPERATIONRESULTSUCCESS']._serialized_start=11124 - _globals['_OPERATIONRESULTSUCCESS']._serialized_end=11194 - _globals['_OPERATIONRESULTFAILURE']._serialized_start=11196 - _globals['_OPERATIONRESULTFAILURE']._serialized_end=11265 - _globals['_OPERATIONACTION']._serialized_start=11268 - _globals['_OPERATIONACTION']._serialized_end=11424 - _globals['_SENDSIGNALACTION']._serialized_start=11427 - _globals['_SENDSIGNALACTION']._serialized_end=11575 - _globals['_STARTNEWORCHESTRATIONACTION']._serialized_start=11578 - _globals['_STARTNEWORCHESTRATIONACTION']._serialized_end=11784 - _globals['_GETWORKITEMSREQUEST']._serialized_start=11786 - _globals['_GETWORKITEMSREQUEST']._serialized_end=11807 - _globals['_WORKITEM']._serialized_start=11810 - _globals['_WORKITEM']._serialized_end=12035 - _globals['_COMPLETETASKRESPONSE']._serialized_start=12037 - _globals['_COMPLETETASKRESPONSE']._serialized_end=12059 - _globals['_HEALTHPING']._serialized_start=12061 - _globals['_HEALTHPING']._serialized_end=12073 - _globals['_TASKHUBSIDECARSERVICE']._serialized_start=12455 - _globals['_TASKHUBSIDECARSERVICE']._serialized_end=13859 + _globals['_ORCHESTRATIONSTATUS']._serialized_start=12097 + _globals['_ORCHESTRATIONSTATUS']._serialized_end=12406 + _globals['_CREATEORCHESTRATIONACTION']._serialized_start=12408 + _globals['_CREATEORCHESTRATIONACTION']._serialized_end=12473 + _globals['_ORCHESTRATIONINSTANCE']._serialized_start=177 + _globals['_ORCHESTRATIONINSTANCE']._serialized_end=271 + _globals['_ACTIVITYREQUEST']._serialized_start=274 + _globals['_ACTIVITYREQUEST']._serialized_end=511 + _globals['_ACTIVITYRESPONSE']._serialized_start=514 + _globals['_ACTIVITYRESPONSE']._serialized_end=659 + _globals['_TASKFAILUREDETAILS']._serialized_start=662 + _globals['_TASKFAILUREDETAILS']._serialized_end=840 + _globals['_PARENTINSTANCEINFO']._serialized_start=843 + _globals['_PARENTINSTANCEINFO']._serialized_end=1034 + _globals['_TRACECONTEXT']._serialized_start=1036 + _globals['_TRACECONTEXT']._serialized_end=1141 + _globals['_EXECUTIONSTARTEDEVENT']._serialized_start=1144 + _globals['_EXECUTIONSTARTEDEVENT']._serialized_end=1536 + _globals['_EXECUTIONCOMPLETEDEVENT']._serialized_start=1539 + _globals['_EXECUTIONCOMPLETEDEVENT']._serialized_end=1706 + _globals['_EXECUTIONTERMINATEDEVENT']._serialized_start=1708 + _globals['_EXECUTIONTERMINATEDEVENT']._serialized_end=1796 + _globals['_TASKSCHEDULEDEVENT']._serialized_start=1799 + _globals['_TASKSCHEDULEDEVENT']._serialized_end=1968 + _globals['_TASKCOMPLETEDEVENT']._serialized_start=1970 + _globals['_TASKCOMPLETEDEVENT']._serialized_end=2061 + _globals['_TASKFAILEDEVENT']._serialized_start=2063 + _globals['_TASKFAILEDEVENT']._serialized_end=2150 + _globals['_SUBORCHESTRATIONINSTANCECREATEDEVENT']._serialized_start=2153 + _globals['_SUBORCHESTRATIONINSTANCECREATEDEVENT']._serialized_end=2360 + _globals['_SUBORCHESTRATIONINSTANCECOMPLETEDEVENT']._serialized_start=2362 + _globals['_SUBORCHESTRATIONINSTANCECOMPLETEDEVENT']._serialized_end=2473 + _globals['_SUBORCHESTRATIONINSTANCEFAILEDEVENT']._serialized_start=2475 + _globals['_SUBORCHESTRATIONINSTANCEFAILEDEVENT']._serialized_end=2582 + _globals['_TIMERCREATEDEVENT']._serialized_start=2584 + _globals['_TIMERCREATEDEVENT']._serialized_end=2647 + _globals['_TIMERFIREDEVENT']._serialized_start=2649 + _globals['_TIMERFIREDEVENT']._serialized_end=2727 + _globals['_ORCHESTRATORSTARTEDEVENT']._serialized_start=2729 + _globals['_ORCHESTRATORSTARTEDEVENT']._serialized_end=2755 + _globals['_ORCHESTRATORCOMPLETEDEVENT']._serialized_start=2757 + _globals['_ORCHESTRATORCOMPLETEDEVENT']._serialized_end=2785 + _globals['_EVENTSENTEVENT']._serialized_start=2787 + _globals['_EVENTSENTEVENT']._serialized_end=2882 + _globals['_EVENTRAISEDEVENT']._serialized_start=2884 + _globals['_EVENTRAISEDEVENT']._serialized_end=2961 + _globals['_GENERICEVENT']._serialized_start=2963 + _globals['_GENERICEVENT']._serialized_end=3021 + _globals['_HISTORYSTATEEVENT']._serialized_start=3023 + _globals['_HISTORYSTATEEVENT']._serialized_end=3091 + _globals['_CONTINUEASNEWEVENT']._serialized_start=3093 + _globals['_CONTINUEASNEWEVENT']._serialized_end=3158 + _globals['_EXECUTIONSUSPENDEDEVENT']._serialized_start=3160 + _globals['_EXECUTIONSUSPENDEDEVENT']._serialized_end=3230 + _globals['_EXECUTIONRESUMEDEVENT']._serialized_start=3232 + _globals['_EXECUTIONRESUMEDEVENT']._serialized_end=3300 + _globals['_HISTORYEVENT']._serialized_start=3303 + _globals['_HISTORYEVENT']._serialized_end=4461 + _globals['_SCHEDULETASKACTION']._serialized_start=4463 + _globals['_SCHEDULETASKACTION']._serialized_end=4589 + _globals['_CREATESUBORCHESTRATIONACTION']._serialized_start=4592 + _globals['_CREATESUBORCHESTRATIONACTION']._serialized_end=4748 + _globals['_CREATETIMERACTION']._serialized_start=4750 + _globals['_CREATETIMERACTION']._serialized_end=4813 + _globals['_SENDEVENTACTION']._serialized_start=4815 + _globals['_SENDEVENTACTION']._serialized_end=4932 + _globals['_COMPLETEORCHESTRATIONACTION']._serialized_start=4935 + _globals['_COMPLETEORCHESTRATIONACTION']._serialized_end=5243 + _globals['_TERMINATEORCHESTRATIONACTION']._serialized_start=5245 + _globals['_TERMINATEORCHESTRATIONACTION']._serialized_end=5358 + _globals['_ORCHESTRATORACTION']._serialized_start=5361 + _globals['_ORCHESTRATORACTION']._serialized_end=5739 + _globals['_ORCHESTRATORREQUEST']._serialized_start=5742 + _globals['_ORCHESTRATORREQUEST']._serialized_end=5960 + _globals['_ORCHESTRATORRESPONSE']._serialized_start=5963 + _globals['_ORCHESTRATORRESPONSE']._serialized_end=6095 + _globals['_CREATEINSTANCEREQUEST']._serialized_start=6098 + _globals['_CREATEINSTANCEREQUEST']._serialized_end=6517 + _globals['_CREATEINSTANCEREQUEST_TAGSENTRY']._serialized_start=6474 + _globals['_CREATEINSTANCEREQUEST_TAGSENTRY']._serialized_end=6517 + _globals['_ORCHESTRATIONIDREUSEPOLICY']._serialized_start=6519 + _globals['_ORCHESTRATIONIDREUSEPOLICY']._serialized_end=6638 + _globals['_CREATEINSTANCERESPONSE']._serialized_start=6640 + _globals['_CREATEINSTANCERESPONSE']._serialized_end=6684 + _globals['_GETINSTANCEREQUEST']._serialized_start=6686 + _globals['_GETINSTANCEREQUEST']._serialized_end=6755 + _globals['_GETINSTANCERESPONSE']._serialized_start=6757 + _globals['_GETINSTANCERESPONSE']._serialized_end=6843 + _globals['_REWINDINSTANCEREQUEST']._serialized_start=6845 + _globals['_REWINDINSTANCEREQUEST']._serialized_end=6934 + _globals['_REWINDINSTANCERESPONSE']._serialized_start=6936 + _globals['_REWINDINSTANCERESPONSE']._serialized_end=6960 + _globals['_ORCHESTRATIONSTATE']._serialized_start=6963 + _globals['_ORCHESTRATIONSTATE']._serialized_end=7639 + _globals['_RAISEEVENTREQUEST']._serialized_start=7641 + _globals['_RAISEEVENTREQUEST']._serialized_end=7739 + _globals['_RAISEEVENTRESPONSE']._serialized_start=7741 + _globals['_RAISEEVENTRESPONSE']._serialized_end=7761 + _globals['_TERMINATEREQUEST']._serialized_start=7763 + _globals['_TERMINATEREQUEST']._serialized_end=7866 + _globals['_TERMINATERESPONSE']._serialized_start=7868 + _globals['_TERMINATERESPONSE']._serialized_end=7887 + _globals['_SUSPENDREQUEST']._serialized_start=7889 + _globals['_SUSPENDREQUEST']._serialized_end=7971 + _globals['_SUSPENDRESPONSE']._serialized_start=7973 + _globals['_SUSPENDRESPONSE']._serialized_end=7990 + _globals['_RESUMEREQUEST']._serialized_start=7992 + _globals['_RESUMEREQUEST']._serialized_end=8073 + _globals['_RESUMERESPONSE']._serialized_start=8075 + _globals['_RESUMERESPONSE']._serialized_end=8091 + _globals['_QUERYINSTANCESREQUEST']._serialized_start=8093 + _globals['_QUERYINSTANCESREQUEST']._serialized_end=8147 + _globals['_INSTANCEQUERY']._serialized_start=8150 + _globals['_INSTANCEQUERY']._serialized_end=8536 + _globals['_QUERYINSTANCESRESPONSE']._serialized_start=8539 + _globals['_QUERYINSTANCESRESPONSE']._serialized_end=8669 + _globals['_PURGEINSTANCESREQUEST']._serialized_start=8672 + _globals['_PURGEINSTANCESREQUEST']._serialized_end=8800 + _globals['_PURGEINSTANCEFILTER']._serialized_start=8803 + _globals['_PURGEINSTANCEFILTER']._serialized_end=8973 + _globals['_PURGEINSTANCESRESPONSE']._serialized_start=8975 + _globals['_PURGEINSTANCESRESPONSE']._serialized_end=9029 + _globals['_CREATETASKHUBREQUEST']._serialized_start=9031 + _globals['_CREATETASKHUBREQUEST']._serialized_end=9079 + _globals['_CREATETASKHUBRESPONSE']._serialized_start=9081 + _globals['_CREATETASKHUBRESPONSE']._serialized_end=9104 + _globals['_DELETETASKHUBREQUEST']._serialized_start=9106 + _globals['_DELETETASKHUBREQUEST']._serialized_end=9128 + _globals['_DELETETASKHUBRESPONSE']._serialized_start=9130 + _globals['_DELETETASKHUBRESPONSE']._serialized_end=9153 + _globals['_SIGNALENTITYREQUEST']._serialized_start=9156 + _globals['_SIGNALENTITYREQUEST']._serialized_end=9326 + _globals['_SIGNALENTITYRESPONSE']._serialized_start=9328 + _globals['_SIGNALENTITYRESPONSE']._serialized_end=9350 + _globals['_GETENTITYREQUEST']._serialized_start=9352 + _globals['_GETENTITYREQUEST']._serialized_end=9412 + _globals['_GETENTITYRESPONSE']._serialized_start=9414 + _globals['_GETENTITYRESPONSE']._serialized_end=9482 + _globals['_ENTITYQUERY']._serialized_start=9485 + _globals['_ENTITYQUERY']._serialized_end=9816 + _globals['_QUERYENTITIESREQUEST']._serialized_start=9818 + _globals['_QUERYENTITIESREQUEST']._serialized_end=9869 + _globals['_QUERYENTITIESRESPONSE']._serialized_start=9871 + _globals['_QUERYENTITIESRESPONSE']._serialized_end=9986 + _globals['_ENTITYMETADATA']._serialized_start=9989 + _globals['_ENTITYMETADATA']._serialized_end=10208 + _globals['_CLEANENTITYSTORAGEREQUEST']._serialized_start=10211 + _globals['_CLEANENTITYSTORAGEREQUEST']._serialized_end=10354 + _globals['_CLEANENTITYSTORAGERESPONSE']._serialized_start=10357 + _globals['_CLEANENTITYSTORAGERESPONSE']._serialized_end=10503 + _globals['_ORCHESTRATORENTITYPARAMETERS']._serialized_start=10505 + _globals['_ORCHESTRATORENTITYPARAMETERS']._serialized_end=10598 + _globals['_ENTITYBATCHREQUEST']._serialized_start=10601 + _globals['_ENTITYBATCHREQUEST']._serialized_end=10731 + _globals['_ENTITYBATCHRESULT']._serialized_start=10734 + _globals['_ENTITYBATCHRESULT']._serialized_end=10919 + _globals['_OPERATIONREQUEST']._serialized_start=10921 + _globals['_OPERATIONREQUEST']._serialized_end=11022 + _globals['_OPERATIONRESULT']._serialized_start=11024 + _globals['_OPERATIONRESULT']._serialized_end=11143 + _globals['_OPERATIONRESULTSUCCESS']._serialized_start=11145 + _globals['_OPERATIONRESULTSUCCESS']._serialized_end=11215 + _globals['_OPERATIONRESULTFAILURE']._serialized_start=11217 + _globals['_OPERATIONRESULTFAILURE']._serialized_end=11286 + _globals['_OPERATIONACTION']._serialized_start=11289 + _globals['_OPERATIONACTION']._serialized_end=11445 + _globals['_SENDSIGNALACTION']._serialized_start=11448 + _globals['_SENDSIGNALACTION']._serialized_end=11596 + _globals['_STARTNEWORCHESTRATIONACTION']._serialized_start=11599 + _globals['_STARTNEWORCHESTRATIONACTION']._serialized_end=11805 + _globals['_GETWORKITEMSREQUEST']._serialized_start=11807 + _globals['_GETWORKITEMSREQUEST']._serialized_end=11828 + _globals['_WORKITEM']._serialized_start=11831 + _globals['_WORKITEM']._serialized_end=12056 + _globals['_COMPLETETASKRESPONSE']._serialized_start=12058 + _globals['_COMPLETETASKRESPONSE']._serialized_end=12080 + _globals['_HEALTHPING']._serialized_start=12082 + _globals['_HEALTHPING']._serialized_end=12094 + _globals['_TASKHUBSIDECARSERVICE']._serialized_start=12476 + _globals['_TASKHUBSIDECARSERVICE']._serialized_end=13880 # @@protoc_insertion_point(module_scope) diff --git a/durabletask/internal/orchestrator_service_pb2_grpc.py b/durabletask/internal/orchestrator_service_pb2_grpc.py index f11cf4b..3638bf6 100644 --- a/durabletask/internal/orchestrator_service_pb2_grpc.py +++ b/durabletask/internal/orchestrator_service_pb2_grpc.py @@ -1,32 +1,10 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc -import warnings +from durabletask.internal import orchestrator_service_pb2 as durabletask_dot_internal_dot_orchestrator__service__pb2 from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2 -# TODO: This is a manual edit. Need to figure out how to not manually edit this file. -import durabletask.internal.orchestrator_service_pb2 as orchestrator__service__pb2 - -GRPC_GENERATED_VERSION = '1.67.0' -GRPC_VERSION = grpc.__version__ -_version_not_supported = False - -try: - from grpc._utilities import first_version_is_lower - _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) -except ImportError: - _version_not_supported = True - -if _version_not_supported: - raise RuntimeError( - f'The grpc package installed is at version {GRPC_VERSION},' - + f' but the generated code in orchestrator_service_pb2_grpc.py depends on' - + f' grpcio>={GRPC_GENERATED_VERSION}.' - + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' - + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' - ) - class TaskHubSidecarServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -41,112 +19,112 @@ def __init__(self, channel): '/TaskHubSidecarService/Hello', request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - _registered_method=True) + ) self.StartInstance = channel.unary_unary( '/TaskHubSidecarService/StartInstance', - request_serializer=orchestrator__service__pb2.CreateInstanceRequest.SerializeToString, - response_deserializer=orchestrator__service__pb2.CreateInstanceResponse.FromString, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.CreateInstanceRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.RewindInstanceRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.RaiseEventRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.TerminateRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.SuspendRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.ResumeRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.QueryInstancesRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.PurgeInstancesRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.GetWorkItemsRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.ActivityResponse.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.OrchestratorResponse.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.EntityBatchResult.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.CreateTaskHubRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.DeleteTaskHubRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.SignalEntityRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.GetEntityRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.QueryEntitiesRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_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, - _registered_method=True) + request_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.CleanEntityStorageRequest.SerializeToString, + response_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.CleanEntityStorageResponse.FromString, + ) class TaskHubSidecarServiceServicer(object): @@ -312,114 +290,113 @@ def add_TaskHubSidecarServiceServicer_to_server(servicer, server): ), 'StartInstance': grpc.unary_unary_rpc_method_handler( servicer.StartInstance, - request_deserializer=orchestrator__service__pb2.CreateInstanceRequest.FromString, - response_serializer=orchestrator__service__pb2.CreateInstanceResponse.SerializeToString, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.CreateInstanceRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.RewindInstanceRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.RaiseEventRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.TerminateRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.SuspendRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.ResumeRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.QueryInstancesRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.PurgeInstancesRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.GetWorkItemsRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.ActivityResponse.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.OrchestratorResponse.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.EntityBatchResult.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.CreateTaskHubRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.DeleteTaskHubRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.SignalEntityRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.GetEntityRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.QueryEntitiesRequest.FromString, + response_serializer=durabletask_dot_internal_dot_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, + request_deserializer=durabletask_dot_internal_dot_orchestrator__service__pb2.CleanEntityStorageRequest.FromString, + response_serializer=durabletask_dot_internal_dot_orchestrator__service__pb2.CleanEntityStorageResponse.SerializeToString, ), } generic_handler = grpc.method_handlers_generic_handler( 'TaskHubSidecarService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) - server.add_registered_method_handlers('TaskHubSidecarService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -437,21 +414,11 @@ def Hello(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/TaskHubSidecarService/Hello', + 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, - _registered_method=True) + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def StartInstance(request, @@ -464,21 +431,11 @@ def StartInstance(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/StartInstance', + durabletask_dot_internal_dot_orchestrator__service__pb2.CreateInstanceRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.CreateInstanceResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetInstance(request, @@ -491,21 +448,11 @@ def GetInstance(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/GetInstance', + durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def RewindInstance(request, @@ -518,21 +465,11 @@ def RewindInstance(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/RewindInstance', + durabletask_dot_internal_dot_orchestrator__service__pb2.RewindInstanceRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.RewindInstanceResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def WaitForInstanceStart(request, @@ -545,21 +482,11 @@ def WaitForInstanceStart(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/WaitForInstanceStart', + durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def WaitForInstanceCompletion(request, @@ -572,21 +499,11 @@ def WaitForInstanceCompletion(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/WaitForInstanceCompletion', + durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.GetInstanceResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def RaiseEvent(request, @@ -599,21 +516,11 @@ def RaiseEvent(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/RaiseEvent', + durabletask_dot_internal_dot_orchestrator__service__pb2.RaiseEventRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.RaiseEventResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def TerminateInstance(request, @@ -626,21 +533,11 @@ def TerminateInstance(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/TerminateInstance', + durabletask_dot_internal_dot_orchestrator__service__pb2.TerminateRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.TerminateResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def SuspendInstance(request, @@ -653,21 +550,11 @@ def SuspendInstance(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/SuspendInstance', + durabletask_dot_internal_dot_orchestrator__service__pb2.SuspendRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.SuspendResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ResumeInstance(request, @@ -680,21 +567,11 @@ def ResumeInstance(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/ResumeInstance', + durabletask_dot_internal_dot_orchestrator__service__pb2.ResumeRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.ResumeResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def QueryInstances(request, @@ -707,21 +584,11 @@ def QueryInstances(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/QueryInstances', + durabletask_dot_internal_dot_orchestrator__service__pb2.QueryInstancesRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.QueryInstancesResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def PurgeInstances(request, @@ -734,21 +601,11 @@ def PurgeInstances(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/PurgeInstances', + durabletask_dot_internal_dot_orchestrator__service__pb2.PurgeInstancesRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.PurgeInstancesResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetWorkItems(request, @@ -761,21 +618,11 @@ def GetWorkItems(request, 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, - _registered_method=True) + return grpc.experimental.unary_stream(request, target, '/TaskHubSidecarService/GetWorkItems', + durabletask_dot_internal_dot_orchestrator__service__pb2.GetWorkItemsRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.WorkItem.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CompleteActivityTask(request, @@ -788,21 +635,11 @@ def CompleteActivityTask(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/CompleteActivityTask', + durabletask_dot_internal_dot_orchestrator__service__pb2.ActivityResponse.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.CompleteTaskResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CompleteOrchestratorTask(request, @@ -815,21 +652,11 @@ def CompleteOrchestratorTask(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/CompleteOrchestratorTask', + durabletask_dot_internal_dot_orchestrator__service__pb2.OrchestratorResponse.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.CompleteTaskResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CompleteEntityTask(request, @@ -842,21 +669,11 @@ def CompleteEntityTask(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/CompleteEntityTask', + durabletask_dot_internal_dot_orchestrator__service__pb2.EntityBatchResult.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.CompleteTaskResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CreateTaskHub(request, @@ -869,21 +686,11 @@ def CreateTaskHub(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/CreateTaskHub', + durabletask_dot_internal_dot_orchestrator__service__pb2.CreateTaskHubRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.CreateTaskHubResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def DeleteTaskHub(request, @@ -896,21 +703,11 @@ def DeleteTaskHub(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/DeleteTaskHub', + durabletask_dot_internal_dot_orchestrator__service__pb2.DeleteTaskHubRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.DeleteTaskHubResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def SignalEntity(request, @@ -923,21 +720,11 @@ def SignalEntity(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/SignalEntity', + durabletask_dot_internal_dot_orchestrator__service__pb2.SignalEntityRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.SignalEntityResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetEntity(request, @@ -950,21 +737,11 @@ def GetEntity(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/GetEntity', + durabletask_dot_internal_dot_orchestrator__service__pb2.GetEntityRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.GetEntityResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def QueryEntities(request, @@ -977,21 +754,11 @@ def QueryEntities(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/QueryEntities', + durabletask_dot_internal_dot_orchestrator__service__pb2.QueryEntitiesRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.QueryEntitiesResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CleanEntityStorage(request, @@ -1004,18 +771,8 @@ def CleanEntityStorage(request, 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, - _registered_method=True) + return grpc.experimental.unary_unary(request, target, '/TaskHubSidecarService/CleanEntityStorage', + durabletask_dot_internal_dot_orchestrator__service__pb2.CleanEntityStorageRequest.SerializeToString, + durabletask_dot_internal_dot_orchestrator__service__pb2.CleanEntityStorageResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) diff --git a/requirements.txt b/requirements.txt index af76d88..a31419b 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1,6 +1,5 @@ autopep8 -grpcio -grpcio-tools +grpcio>=1.60.0 # 1.60.0 is the version introducing protobuf 1.25.X support, newer versions are backwards compatible protobuf pytest -pytest-cov \ No newline at end of file +pytest-cov