264
}
265
} else {
266
>
// Workflow batch types process tasks via executionInfo, not
activities.go
267
>
// targetExecutionInfo; convert the target executions
268
>
// (business_id/run_id) into WorkflowExecutionInfo.
269
>
executionInfos := make([]*workflowpb.WorkflowExecutionInfo, 0, len(config.initialTargetExecutions))
270
>
for _, exec := range config.initialTargetExecutions {
271
>
executionInfos = append(executionInfos, &workflowpb.WorkflowExecutionInfo{
272
>
Execution: &commonpb.WorkflowExecution{
273
>
WorkflowId: exec.GetBusinessId(),
274
>
RunId: exec.GetRunId(),
275
>
},
276
>
})
277
>
}
278
>
p = &page{
279
>
executionInfos: executionInfos,
280
>
nextPageToken: config.initialPageToken,
281
>
pageNumber: hbd.CurrentPage,
282
>
}
283
}
284
} else if len(config.initialExecutions) > 0 {