Skip to content

Commit 4f05e91

Browse files
Copilotdanielgerlag
andcommitted
Fix PostgreSQL DateTime issue in ActivityController
Co-authored-by: danielgerlag <[email protected]>
1 parent bf8a65a commit 4f05e91

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/WorkflowCore/Services/ActivityController.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public async Task<PendingActivity> GetPendingActivity(string activityName, strin
3434
{
3535
if (!firstPass)
3636
await Task.Delay(100);
37-
subscription = await _subscriptionRepository.GetFirstOpenSubscription(Event.EventTypeActivity, activityName, _dateTimeProvider.Now);
37+
subscription = await _subscriptionRepository.GetFirstOpenSubscription(Event.EventTypeActivity, activityName, _dateTimeProvider.UtcNow);
3838
if (subscription != null)
3939
if (!await _lockProvider.AcquireLock($"sub:{subscription.Id}", CancellationToken.None))
4040
subscription = null;
@@ -51,7 +51,7 @@ public async Task<PendingActivity> GetPendingActivity(string activityName, strin
5151
Token = token.Encode(),
5252
ActivityName = subscription.EventKey,
5353
Parameters = subscription.SubscriptionData,
54-
TokenExpiry = DateTime.MaxValue
54+
TokenExpiry = new DateTime(DateTime.MaxValue.Ticks, DateTimeKind.Utc)
5555
};
5656

5757
if (!await _subscriptionRepository.SetSubscriptionToken(subscription.Id, result.Token, workerId, result.TokenExpiry))

0 commit comments

Comments
 (0)