Skip to content

Commit 07a4472

Browse files
committed
feat(createEntities): Add concurrency param
1 parent 5c93b7d commit 07a4472

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

lib/tasks/push-to-space/creation.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import { logEmitter } from 'contentful-batch-libs/dist/logging'
1111
* Applies to all entities except Entries, as the CMA API for those is slightly different
1212
* See handleCreationErrors for details on what errors reject the promise or not.
1313
*/
14-
export function createEntities (context, entities, destinationEntities) {
14+
export function createEntities (context, entities, destinationEntities, concurrency = 6) {
1515
return Promise.map(entities, (entity) => {
1616
const destinationEntity = getDestinationEntityForSourceEntity(destinationEntities, entity.transformed)
1717
const operation = destinationEntity ? 'update' : 'create'
@@ -21,7 +21,7 @@ export function createEntities (context, entities, destinationEntities) {
2121
return promise
2222
.then(partial(creationSuccessNotifier, operation))
2323
.catch(partial(handleCreationErrors, entity))
24-
}, {concurrency: 6})
24+
}, {concurrency})
2525
}
2626

2727
/**

lib/tasks/push-to-space/push-to-space.js

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,8 @@ export default function pushToSpace ({
8787
return creation.createEntities(
8888
{ target: ctx.environment, type: 'Locale' },
8989
sourceData.locales,
90-
destinationData.locales
90+
destinationData.locales,
91+
1
9192
)
9293
.then((locales) => {
9394
ctx.data.locales = locales

0 commit comments

Comments
 (0)