959
ctx context.Context,
960
request *p.GetCurrentExecutionRequest,
962
>
query := d.Session.Query(templateGetCurrentExecutionQuery,
963
>
request.ShardID,
964
>
rowTypeExecution,
965
>
request.NamespaceID,
966
>
request.WorkflowID,
967
>
d.getCurrentRecordRunID(request.ArchetypeID),
968
>
defaultVisibilityTimestamp,
969
>
rowTypeExecutionTaskID,
970
>
).WithContext(ctx)
971
>
972
>
result := make(map[string]any)
973
>
if err := query.MapScan(result); err != nil {
974
return nil, gocql.ConvertError("GetCurrentExecution", err)
975
}