@@ -120,7 +120,17 @@ function parseArgs(): ScriptOptions {
120120 process . exit ( 1 )
121121 }
122122
123- return { pageSize, concurrency, pageDelayMs, workflowDelayMs, startAfter, dryRun, limit, maxPages, emptyPageDelayMs }
123+ return {
124+ pageSize,
125+ concurrency,
126+ pageDelayMs,
127+ workflowDelayMs,
128+ startAfter,
129+ dryRun,
130+ limit,
131+ maxPages,
132+ emptyPageDelayMs,
133+ }
124134}
125135
126136// Returns a page of distinct memberIds from memberOrganizations, cursor-based.
@@ -257,7 +267,9 @@ async function main() {
257267 log . info ( `Mode: ${ opts . dryRun ? 'DRY RUN' : 'LIVE' } ` )
258268 log . info ( `Limit: ${ opts . limit ?? '(none)' } ` )
259269 log . info ( `Max pages: ${ opts . maxPages ?? '(none)' } ` )
260- log . info ( `Empty page delay: ${ opts . emptyPageDelayMs !== null ? `${ opts . emptyPageDelayMs } ms` : `same as page-delay (${ opts . pageDelayMs } ms)` } ` )
270+ log . info (
271+ `Empty page delay: ${ opts . emptyPageDelayMs !== null ? `${ opts . emptyPageDelayMs } ms` : `same as page-delay (${ opts . pageDelayMs } ms)` } ` ,
272+ )
261273 log . info ( '=' . repeat ( 80 ) )
262274
263275 const dbConnection = await getDbConnection ( WRITE_DB_CONFIG ( ) )
@@ -324,8 +336,8 @@ async function main() {
324336 opts . concurrency ,
325337 async ( { memberId, activeOrgIds, staleOrgIds } ) => {
326338 log . info (
327- `Triggering memberUpdate for broken member: ${ memberId } | stale orgs: [${ staleOrgIds . join ( ', ' ) } ] | active orgs: ${ activeOrgIds . length } ` ,
328- )
339+ `Triggering memberUpdate for broken member: ${ memberId } | stale orgs: [${ staleOrgIds . join ( ', ' ) } ] | active orgs: ${ activeOrgIds . length } ` ,
340+ )
329341 await temporal . workflow . start ( 'memberUpdate' , {
330342 taskQueue : 'profiles' ,
331343 workflowId : `member-update/${ DEFAULT_TENANT_ID } /${ memberId } ` ,
@@ -371,9 +383,10 @@ async function main() {
371383 hasMore = false
372384 }
373385
374- const delayMs = brokenMembers . length === 0 && opts . emptyPageDelayMs !== null
375- ? opts . emptyPageDelayMs
376- : opts . pageDelayMs
386+ const delayMs =
387+ brokenMembers . length === 0 && opts . emptyPageDelayMs !== null
388+ ? opts . emptyPageDelayMs
389+ : opts . pageDelayMs
377390 if ( delayMs > 0 ) {
378391 await new Promise ( ( resolve ) => setTimeout ( resolve , delayMs ) )
379392 }
0 commit comments