Skip to content

Commit

Permalink
IWF-186: Adjust time converstion
Browse files Browse the repository at this point in the history
  • Loading branch information
lwolczynski committed Oct 9, 2024
1 parent 596a1c3 commit 53f052c
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion service/api/temporal/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -273,7 +273,7 @@ func (t *temporalClient) DescribeWorkflowExecution(
Status: status,
SearchAttributes: searchAttributes,
Memos: memo,
WorkflowStartedTimestamp: resp.GetWorkflowExecutionInfo().GetStartTime().GetSeconds() + int64(resp.GetWorkflowExecutionInfo().GetStartTime().GetNanos()),
WorkflowStartedTimestamp: resp.GetWorkflowExecutionInfo().GetStartTime().GetSeconds()*1000*1000*1000 + int64(resp.GetWorkflowExecutionInfo().GetStartTime().GetNanos()),
}, err
}

Expand Down
2 changes: 1 addition & 1 deletion service/api/temporal/reset.go
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,7 @@ OuterLoop:
}
for _, e := range resp.GetHistory().GetEvents() {
if e.GetEventType() == enums.EVENT_TYPE_WORKFLOW_TASK_COMPLETED {
if e.GetEventTime().GetSeconds()+int64(e.GetEventTime().GetNanos()) >= earliestTime {
if e.GetEventTime().GetSeconds()*1000*1000*1000+int64(e.GetEventTime().GetNanos()) >= earliestTime {
decisionFinishID = e.GetEventId()
break OuterLoop
}
Expand Down

0 comments on commit 53f052c

Please sign in to comment.