|
|
@ -244,13 +244,13 @@ async function revertPendingSyncs() {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// First, revert 'pending' syncs:
|
|
|
|
// First, revert 'pending' syncs:
|
|
|
|
await revertPendingSyncs();
|
|
|
|
//await revertPendingSyncs();
|
|
|
|
|
|
|
|
|
|
|
|
/** Second, for each option contract, get all of its quotes.
|
|
|
|
/** Second, for each option contract, get all of its quotes.
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* This queries Polygon with a concurrency of 6.
|
|
|
|
* This queries Polygon with a concurrency of 6.
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
const q = new pQueue({ concurrency: 6 });
|
|
|
|
const q = new pQueue({ concurrency: 60 });
|
|
|
|
/** Initialized with the lowest possible option contract.
|
|
|
|
/** Initialized with the lowest possible option contract.
|
|
|
|
* It's passed into `getNextUnstartedSymbolAndAsOfDate()`.
|
|
|
|
* It's passed into `getNextUnstartedSymbolAndAsOfDate()`.
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|