Skip to content

Commit 1efecab

Browse files
committed
Cleanup
1 parent 13e964f commit 1efecab

File tree

3 files changed

+2
-13
lines changed

3 files changed

+2
-13
lines changed

src/WorkflowCore/Interface/Persistence/ITransaction.cs

Lines changed: 0 additions & 10 deletions
This file was deleted.

src/WorkflowCore/Services/WorkflowController.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ public Task<string> StartWorkflow<TData>(string workflowId, TData data = null, s
5353
return StartWorkflow(workflowId, null, data, reference);
5454
}
5555

56-
public async Task<string> StartWorkflow<TData>(string workflowId, int? version, TData data = null, string reference=null, ITransaction transaction = null)
56+
public async Task<string> StartWorkflow<TData>(string workflowId, int? version, TData data = null, string reference=null)
5757
where TData : class, new()
5858
{
5959

@@ -91,7 +91,7 @@ public async Task<string> StartWorkflow<TData>(string workflowId, int? version,
9191
await middlewareRunner.RunPreMiddleware(wf, def);
9292
}
9393

94-
string id = await _persistenceStore.CreateNewWorkflow(wf, transaction);
94+
string id = await _persistenceStore.CreateNewWorkflow(wf);
9595
await _queueProvider.QueueWork(id, QueueType.Workflow);
9696
await _queueProvider.QueueWork(id, QueueType.Index);
9797
await _eventHub.PublishNotification(new WorkflowStarted

src/providers/WorkflowCore.Persistence.MongoDB/Services/MongoPersistenceProvider.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,6 @@ static void CreateIndexes(MongoPersistenceProvider instance)
126126
public async Task<string> CreateNewWorkflow(WorkflowInstance workflow, CancellationToken cancellationToken = default)
127127
{
128128
await WorkflowInstances.InsertOneAsync(workflow, cancellationToken: cancellationToken);
129-
130129
return workflow.Id;
131130
}
132131

0 commit comments

Comments
 (0)