File tree Expand file tree Collapse file tree
packages/trigger-sdk/src/v3 Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1631,6 +1631,10 @@ export async function batchTriggerAndWaitTasks<TTasks extends readonly AnyTask[]
16311631 }
16321632}
16331633
1634+ export function uniqueBatchTaskIdentifiers ( items : BatchItemNDJSON [ ] ) : string [ ] {
1635+ return Array . from ( new Set ( items . map ( ( item ) => item . task ) ) ) . sort ( ) ;
1636+ }
1637+
16341638/**
16351639 * Helper function that executes a 2-phase batch trigger:
16361640 * 1. Creates the batch record with expected run count
@@ -1644,10 +1648,6 @@ export async function batchTriggerAndWaitTasks<TTasks extends readonly AnyTask[]
16441648 * @param requestOptions - Optional request options
16451649 * @internal
16461650 */
1647- export function uniqueBatchTaskIdentifiers ( items : BatchItemNDJSON [ ] ) : string [ ] {
1648- return Array . from ( new Set ( items . map ( ( item ) => item . task ) ) ) . sort ( ) ;
1649- }
1650-
16511651async function executeBatchTwoPhase (
16521652 apiClient : ReturnType < typeof apiClientManager . clientOrThrow > ,
16531653 items : BatchItemNDJSON [ ] ,
You can’t perform that action at this time.
0 commit comments