elsa-core/src/modules/Elsa.Workflows.Runtime/Services
Sipke Schoorstra 7fadf51be6
Fix Output Persistence of Async Activities (#6542)
* Updated output handling of asynchronously run workflows to be the same as when run synchronously

* updated tests

* Refactor activity execution mapping and output persistence

Introduced `GetPersistableOutputAsync` in `IActivityExecutionMapper` to streamline output persistence logic. Refactored the handling of activity persistence properties, replacing repetitive code with reusable methods. Removed unused dependencies and redundant methods, optimizing code readability and maintainability.

* Remove docker-compose-datadog.yml from solution file.

The docker-compose-datadog.yml file is no longer included in the solution structure. This change cleans up unused references to ensure the solution remains consistent and up-to-date.

* Refactor workflow extensions and add new utilities

Split and reorganize workflow-related extension methods into `RunActivityExtensions` and `RunWorkflowExtensions` for better modularity. Removed deprecated methods from `ServiceProviderExtensions`. Updated tests and usages to reflect these changes.

---------

Co-authored-by: Bob Hauser <rhauser@kinaxis.com>
2025-04-01 07:53:00 +02:00
..
ActivityExecutionService.cs
BackgroundActivityInvoker.cs Fix Output Persistence of Async Activities (#6542) 2025-04-01 07:53:00 +02:00
BackgroundStimulusDispatcher.cs Fix race condition in Distributed Workflow Runtime during same-workflow event publishing (#6538) 2025-03-31 18:11:27 +02:00
BackgroundTaskDispatcher.cs
BackgroundWorkflowCancellationDispatcher.cs
BackgroundWorkflowDispatcher.cs Add support for starting new trace contexts in workflows 2025-03-15 21:14:10 +01:00
BookmarkBoundWorkflowService.cs
BookmarkPersister.cs Implement multitenant HTTP routing (#6031) 2024-10-14 21:27:11 +02:00
BookmarkQueueProcessor.cs Fix race condition and add rate limiting to bookmark queue processing (#6187) 2024-12-07 17:34:10 +01:00
BookmarkQueueSignaler.cs Fix race condition and add rate limiting to bookmark queue processing (#6187) 2024-12-07 17:34:10 +01:00
BookmarkQueueWorker.cs Fix race condition and add rate limiting to bookmark queue processing (#6187) 2024-12-07 17:34:10 +01:00
BookmarkResumer.cs Add Elsa.Kafka Module for Kafka Integration with Message Sending and Receiving Activities (#6108) 2024-11-18 13:42:54 +01:00
BookmarkUpdater.cs Refactor workflow state persistence for improved consistency. 2025-01-27 20:07:23 +01:00
DefaultActivityExecutionManager.cs
DefaultActivityExecutionMapper.cs Fix Output Persistence of Async Activities (#6542) 2025-04-01 07:53:00 +02:00
DefaultBookmarkManager.cs Fix all broken summary xml docs (#6123) 2024-11-18 13:41:27 +01:00
DefaultBookmarkQueuePurger.cs Based on default scheduling, DefaultBookmarkQueuePurger logs two low value information entries every 10 seconds. 2025-02-26 15:10:41 -05:00
DefaultCommitStateHandler.cs Refactor commit state handling with a strategy-based approach 2025-01-30 11:59:47 +01:00
DefaultRegistriesPopulator.cs Add multitenancy support for background tasks (#6059) 2024-10-28 19:38:24 +01:00
DefaultWorkflowActivationStrategyEvaluator.cs Add workflow activation and startup services. (#6076) 2024-10-30 22:51:14 +01:00
DefaultWorkflowDefinitionStorePopulator.cs Update namespaces and correct merge artefacts 2024-10-11 20:41:49 +02:00
DefaultWorkflowRegistry.cs
DefaultWorkflowRestarter.cs Add workflow restart functionality for handling interruptions 2025-02-22 15:10:52 +01:00
DefaultWorkflowStarter.cs Merge branch 'main' into enh/workflowinstance-name 2025-03-14 23:03:33 +01:00
EventPublisher.cs Fix race condition in Distributed Workflow Runtime during same-workflow event publishing (#6538) 2025-03-31 18:11:27 +02:00
HeartbeatGenerator.cs Add migration files for database schema V3.4 2025-02-22 20:48:56 +01:00
LocalBackgroundActivityScheduler.cs Introduce job unscheduling functionality 2024-12-05 19:25:16 +01:00
LocalWorkflowClient.cs Merge branch 'main' into enh/workflowinstance-name 2025-03-14 23:03:33 +01:00
LocalWorkflowRuntime.cs Refactor initialization of ObsoleteWorkflowRuntime. 2025-01-28 13:53:22 +01:00
LocalWorkflowRuntime.Obsolete.cs Refactor initialization of ObsoleteWorkflowRuntime. 2025-01-28 13:53:22 +01:00
ObsoleteWorkflowRuntime.cs Fixed from the master merge 2025-03-10 15:52:10 +02:00
StimulusProxyWorkflowInbox.cs Fixed from the master merge 2025-03-10 15:52:10 +02:00
StimulusSender.cs Add CorrelationId to NewBookmarkQueueItem 2025-02-15 12:43:58 +02:00
StoreActivityExecutionLogSink.cs Refactor activity context management and state handling. 2025-01-28 20:24:53 +01:00
StoreBookmarkQueue.cs Add CorrelationId to NewBookmarkQueueItem 2025-02-15 12:43:58 +02:00
StoreWorkflowExecutionLogSink.cs Refactor workflow state persistence for improved consistency. 2025-01-27 20:07:23 +01:00
SynchronousTaskDispatcher.cs
TaskReporter.cs Refactor code for improved clarity and modern syntax 2025-02-15 00:12:52 +01:00
TriggerBoundWorkflowService.cs
TriggerIndexer.cs Add Elsa.Kafka Module for Kafka Integration with Message Sending and Receiving Activities (#6108) 2024-11-18 13:42:54 +01:00
TriggerInvoker.cs Add support for passing initial variables 2025-03-08 11:47:58 +01:00
ValidatingWorkflowDispatcher.cs
WorkflowCanceler.cs Add workflow cancellation notifications (#6075) 2024-10-30 19:46:36 +01:00
WorkflowCancellationService.cs Add workflow cancellation notifications (#6075) 2024-10-30 19:46:36 +01:00
WorkflowDefinitionRefresher.cs
WorkflowDefinitionsReloader.cs
WorkflowExecutionLogRecordExtractor.cs Introduce Log Persistence Strategy (#6057) 2024-10-25 19:41:10 +02:00
WorkflowHeartbeatGeneratorFactory.cs Rename variable for clarity in heartbeat generator logic. 2025-02-22 21:27:15 +01:00
WorkflowHost.cs Add support for activity output testing (#6529) 2025-03-31 18:10:59 +02:00
WorkflowHostFactory.cs Update namespaces and correct merge artefacts 2024-10-11 20:41:49 +02:00
WorkflowInvoker.cs Update namespaces and correct merge artefacts 2024-10-11 20:41:49 +02:00
WorkflowMatcher.cs Update namespaces and correct merge artefacts 2024-10-11 20:41:49 +02:00