aboutsummaryrefslogtreecommitdiff
path: root/src/server
diff options
context:
space:
mode:
Diffstat (limited to 'src/server')
-rw-r--r--src/server/apis/google/GooglePhotosUploadUtils.ts6
-rw-r--r--src/server/index.ts4
2 files changed, 8 insertions, 2 deletions
diff --git a/src/server/apis/google/GooglePhotosUploadUtils.ts b/src/server/apis/google/GooglePhotosUploadUtils.ts
index 9733c7ec5..9275bf125 100644
--- a/src/server/apis/google/GooglePhotosUploadUtils.ts
+++ b/src/server/apis/google/GooglePhotosUploadUtils.ts
@@ -80,7 +80,11 @@ export namespace GooglePhotosUploadUtils {
});
})).newMediaItemResults;
};
- const newMediaItemResults = await newMediaItems.batchedMapInterval({ batchSize: 50 }, createFromUploadTokens, 0.1);
+ const batcher = { batchSize: 50 };
+ const interval = { magnitude: 100, unit: TimeUnit.Milliseconds };
+
+ const newMediaItemResults = await newMediaItems.batchedMapInterval(batcher, createFromUploadTokens, interval);
+
return { newMediaItemResults };
};
diff --git a/src/server/index.ts b/src/server/index.ts
index 7fe2ba132..83bbe734b 100644
--- a/src/server/index.ts
+++ b/src/server/index.ts
@@ -869,8 +869,10 @@ app.post(RouteStore.googlePhotosMediaUpload, async (req, res) => {
}
return newMediaItems;
};
+ const batcher = { batchSize: 25 };
+ const interval = { magnitude: 100, unit: TimeUnit.Milliseconds };
- const newMediaItems = await mediaInput.batchedMapInterval({ batchSize: 25 }, dispatchUpload, 0.1);
+ const newMediaItems = await mediaInput.batchedMapInterval(batcher, dispatchUpload, interval);
if (failed) {
return _error(res, tokenError);