src/DurableTask.Core/Logging/StructuredEventSource.cs (20 lines): - line 283: // TODO: Use WriteEventCore for better performance - line 311: // TODO: Use WriteEventCore for better performance - line 452: // TODO: Use WriteEventCore for better performance - line 495: // TODO: Use WriteEventCore for better performance - line 519: // TODO: Use WriteEventCore for better performance - line 544: // TODO: Use WriteEventCore for better performance - line 569: // TODO: Use WriteEventCore for better performance - line 614: // TODO: Use WriteEventCore for better performance - line 637: // TODO: Use WriteEventCore for better performance - line 661: // TODO: Use WriteEventCore for better performance - line 688: // TODO: Use WriteEventCore for better performance - line 712: // TODO: Use WriteEventCore for better performance - line 734: // TODO: Use WriteEventCore for better performance - line 758: // TODO: Use WriteEventCore for better performance - line 783: // TODO: Use WriteEventCore for better performance - line 808: // TODO: Use WriteEventCore for better performance - line 852: // TODO: Use WriteEventCore for better performance - line 876: // TODO: Use WriteEventCore for better performance - line 921: // TODO: Use WriteEventCore for better performance - line 938: // TODO: Use WriteEventCore for better performance src/DurableTask.AzureStorage/AzureStorageOrchestrationService.cs (7 lines): - line 250: // TODO: More validation. - line 980: // TODO Chris said that there is not case in this root. Double check or write test to prove it. - line 1002: // TODO: When distributed correlation is merged, use that instead. - line 1226: // TODO: https://github.com/Azure/azure-functions-durable-extension/issues/332 - line 1670: // TODO: Need to reason about exception delays - line 1677: // TODO: Need to reason about exception delays - line 2091: // TODO: Change this to a sticky assignment so that partition count changes can src/DurableTask.ServiceBus/ServiceBusOrchestrationService.cs (7 lines): - line 290: // TODO : call shutdown of any remaining orchestrationSessions and orchestrationMessages - line 543: // TODO : Here and elsewhere, consider standard retry block instead of our own hand rolled version - line 615: // TODO: Duplicate detection: Check if the orchestration already finished - line 1093: // TODO: GetOrchestrationState is still flaky as we are fetching from 2 tables while messages are being deleted and added - line 1335: // TODO : Once we change the exception model, check for inner exception - line 1505: // TODO : send batch to instance store, it can write it as individual if it chooses - line 1572: // TODO : take context from the dispatcher and use that to format logs src/DurableTask.Core/TaskOrchestrationExecutor.cs (4 lines): - line 141: // TODO: Log a verbose message indicating that the replay has started (include event count?) - line 146: // TODO: Log a verbose message indicating that new events are being processed (include event count?) - line 151: // TODO: Create a setting that allows orchestrations to complete when the orchestrator - line 176: // TODO: It is an error if result is not completed when all OpenTasks are done. src/DurableTask.Core/TaskOrchestrationDispatcher.cs (3 lines): - line 226: // TODO: Remove this code - it looks incorrect and dangerous - line 353: // TODO : mark an orchestration as faulted if there is data corruption - line 442: // TODO: Exception handling for invalid decisions, which is increasingly likely src/DurableTask.Emulator/LocalOrchestrationService.cs (3 lines): - line 87: // TODO : unobserved task exception (AFFANDAR) - line 444: // TODO : make async (AFFANDAR) - line 630: // TODO : add expiration if we want to unit test it (AFFANDAR) src/DurableTask.Emulator/PeekLockSessionQueue.cs (3 lines): - line 104: // TODO : throw proper lock lost exception (AFFANDAR) - line 145: // TODO : throw proper lock lost exception (AFFANDAR) - line 151: // TODO : note that this we are adding to the tail of the queue rather than head, which is what sbus would actually do (AFFANDAR) src/DurableTask.ServiceBus/Stats/ServiceBusOrchestrationServiceStats.cs (2 lines): - line 21: // TODO: This should implement an interface so implementation specific perf counter implementations are possible - line 22: // TODO: Add: src/DurableTask.ServiceBus/Tracking/AzureTableClient.cs (2 lines): - line 137: // TODO: Enable segmented query for paging purpose - line 258: // TODO : for now we don't have indexes for anything other than the src/DurableTask.AzureStorage/Messaging/TaskHubQueue.cs (1 line): - line 175: // TODO this might not happen, however, in case happen, introduce NullObjectTraceContext. src/DurableTask.Core/ISupportsDurableTraceContext.cs (1 line): - line 63: // TODO: update trace flags casting to handle 2 digits src/DurableTask.AzureServiceFabric/IFabricProviderClient.cs (1 line): - line 26: /// TODO: Enable this functionality via if this is helpful for other providers src/DurableTask.Core/Command/ScheduleTaskOrchestratorAction.cs (1 line): - line 42: // TODO: This property is not used and should be removed or made obsolete src/DurableTask.Core/History/ExecutionStartedEvent.cs (1 line): - line 86: // TODO: Make this property obsolete src/DurableTask.AzureStorage/Tracking/TableEntityConverter.cs (1 line): - line 255: // TODO: Add support for BinaryData if necessary src/DurableTask.AzureStorage/Storage/Table.cs (1 line): - line 63: // TODO: Re-evaluate the use of an "Exists" method as it was intentional omitted from the client API src/DurableTask.ServiceBus/Common/ServiceBusUtils.cs (1 line): - line 124: // TODO : Test more if this helps, initial tests shows not change in performance src/DurableTask.ServiceBus/Settings/ServiceBusOrchestrationServiceSettings.cs (1 line): - line 109: /// TODO: move this setting into ServiceBusSessionSettings and ServiceBusMessageSettings. src/DurableTask.AzureStorage/Tracking/AzureTableTrackingStore.cs (1 line): - line 833: // TODO: Translating null to "null" is a temporary workaround. We should prioritize src/DurableTask.ServiceBus/Tracking/JumpStartManager.cs (1 line): - line 83: // TODO: Query in batches and change time frame only after current range is finished src/DurableTask.Core/Settings/CorrelationSettings.cs (1 line): - line 47: /// TODO Need to discuss the design for referencing Settings from DurableTask.Core side. src/DurableTask.AzureStorage/MessageManager.cs (1 line): - line 157: // TODO: Deserialize with Stream? src/DurableTask.Core/WorkItemDispatcher.cs (1 line): - line 304: // TODO : dump full node context here src/DurableTask.Core/HttpCorrelationProtocolTraceContext.cs (1 line): - line 51: CurrentActivity.SetParentId(context.ParentId); // TODO check if it is context.ParentId or context.CurrentActivity.Id src/DurableTask.ServiceBus/Settings/ServiceBusMessageSettings.cs (1 line): - line 20: /// TODO: add a flag OverflowEnabled to indicate if the overflow settings are enabled src/DurableTask.AzureStorage/Storage/BlobContainer.cs (1 line): - line 49: // TODO: Any encryption scope? src/DurableTask.ServiceBus/Tracking/AzureTableOrchestrationStateEntity.cs (1 line): - line 69: // TODO : additional indexes for efficient querying in the future src/DurableTask.Core/TaskEntityDispatcher.cs (1 line): - line 231: // TODO : mark an orchestration as faulted if there is data corruption src/DurableTask.AzureServiceFabric/FabricOrchestrationServiceClient.cs (1 line): - line 161: // TODO: Renmove from FabricOrchestrationService.SessionInfo dictionary and SessionProvider.lockedSessions src/DurableTask.Core/History/TimerFiredEvent.cs (1 line): - line 63: // TODO : wire format change. (AFFANDAR) src/DurableTask.Core/TraceContextFactory.cs (1 line): - line 85: // ParentId = activity.Id // TODO check if it necessary src/DurableTask.Core/IOrchestrationService.cs (1 line): - line 21: // TODO : MASTER (AFFANDAR) src/DurableTask.Core/TaskOrchestrationContext.cs (1 line): - line 273: // TODO: Emit a log message that the timer is cancelled. src/DurableTask.AzureServiceFabric/Remote/RemoteOrchestrationServiceClient.cs (1 line): - line 317: // TODO: Improve exception handling