@@ -631,16 +631,16 @@ func (e *Engine) startExecution(ctx context.Context, wrappedTriggerEvent enqueue
631631 e .loggerLabels .Store (& loggerLabels )
632632 lggr := e .logger ().With (platform .KeyOrganizationID , organizationID )
633633
634- var executionTimestamp int64
634+ var executionTimestamp time. Time
635635 if tsErr := e .cfg .LocalLimiters .ExecutionTimestampsEnabled .AllowErr (ctx ); tsErr == nil {
636636 executionTimeProvider := NewDonTimeProvider (e .cfg .DonTimeStore , fullExecutionID , lggr )
637637 donTime , dtErr := executionTimeProvider .GetDONTime ()
638638 if dtErr != nil {
639- executionTimestamp = e .cfg .Clock .Now (). UnixMilli ()
640- lggr .Warnw ("Failed to get DON time for execution timestamp, falling back to local time" , "err" , dtErr )
639+ executionTimestamp = e .cfg .Clock .Now ()
640+ lggr .Warnw ("Failed to get DON time for execution timestamp, falling back to local time" , "err" , dtErr , "executionTimestamp" , executionTimestamp )
641641 e .metrics .IncrementExecutionTimestampFallbackCounter (ctx )
642642 } else {
643- executionTimestamp = donTime . UnixMilli ()
643+ executionTimestamp = donTime
644644 lggr .Debugw ("Execution timestamp assigned" , "executionTimestamp" , executionTimestamp )
645645 e .metrics .IncrementExecutionTimestampAssignedCounter (ctx )
646646 }
@@ -649,7 +649,7 @@ func (e *Engine) startExecution(ctx context.Context, wrappedTriggerEvent enqueue
649649 triggerEvent := wrappedTriggerEvent .event .Event
650650
651651 var executionID string
652- if e .cfg .FeatureFlags .FeatureMultiTriggerExecutionIDs .Check (ctx , config .Timestamp (executionTimestamp )) == nil {
652+ if e .cfg .FeatureFlags .FeatureMultiTriggerExecutionIDs .Check (ctx , config .NewTimestamp (executionTimestamp )) == nil {
653653 executionID = fullExecutionID
654654 e .metrics .IncrementExecutionIDFullCounter (ctx )
655655 } else {
0 commit comments